Package org.apache.wayang.ml4all.algorithms.kmeans

Class KMeansCompute

java.lang.Object

org.apache.wayang.ml4all.abstraction.api.LogicalOperator

org.apache.wayang.ml4all.abstraction.api.Compute<Tuple2<Integer,Tuple2<Integer,double[]>>,double[]>

org.apache.wayang.ml4all.algorithms.kmeans.KMeansCompute

All Implemented Interfaces:

Serializable

public class KMeansCompute
extends Compute<Tuple2<Integer,Tuple2<Integer,double[]>>,double[]>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
KMeansCompute()

Method Summary

Modifier and Type	Method	Description
Tuple2<Integer,Tuple2<Integer,double[]>>	aggregate(Tuple2<Integer,Tuple2<Integer,double[]>> input1, Tuple2<Integer,Tuple2<Integer,double[]>> input2)	Aggregates the output of the process() method to use in a group by
Tuple2	process(double[] input, ML4allModel model)	Performs a computation at the data unit granularity

Methods inherited from class org.apache.wayang.ml4all.abstraction.api.LogicalOperator

finalise, initialise

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KMeansCompute

public KMeansCompute()

Method Details

process

public Tuple2 process(double[] input,
 ML4allModel model)

Description copied from class: Compute

Performs a computation at the data unit granularity

Specified by:

process in class Compute<Tuple2<Integer,Tuple2<Integer,double[]>>,double[]>

Parameters:

input - a data unit

aggregate

public Tuple2<Integer,Tuple2<Integer,double[]>> aggregate(Tuple2<Integer,Tuple2<Integer,double[]>> input1,
 Tuple2<Integer,Tuple2<Integer,double[]>> input2)

Description copied from class: Compute

Aggregates the output of the process() method to use in a group by

Specified by:

aggregate in class Compute<Tuple2<Integer,Tuple2<Integer,double[]>>,double[]>