Class KMeans.CentroidAverager
- java.lang.Object
-
- org.apache.flink.examples.java.clustering.KMeans.CentroidAverager
-
- All Implemented Interfaces:
Serializable,org.apache.flink.api.common.functions.Function,org.apache.flink.api.common.functions.MapFunction<org.apache.flink.api.java.tuple.Tuple3<Integer,KMeans.Point,Long>,KMeans.Centroid>
- Enclosing class:
- KMeans
public static final class KMeans.CentroidAverager extends Object implements org.apache.flink.api.common.functions.MapFunction<org.apache.flink.api.java.tuple.Tuple3<Integer,KMeans.Point,Long>,KMeans.Centroid>
Computes new centroid from coordinate sum and count of points.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description CentroidAverager()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description KMeans.Centroidmap(org.apache.flink.api.java.tuple.Tuple3<Integer,KMeans.Point,Long> value)
-
-
-
Method Detail
-
map
public KMeans.Centroid map(org.apache.flink.api.java.tuple.Tuple3<Integer,KMeans.Point,Long> value)
- Specified by:
mapin interfaceorg.apache.flink.api.common.functions.MapFunction<org.apache.flink.api.java.tuple.Tuple3<Integer,KMeans.Point,Long>,KMeans.Centroid>
-
-