Package | Description |
---|---|
org.apache.flink.examples.java.clustering | |
org.apache.flink.examples.java.clustering.util |
Modifier and Type | Class and Description |
---|---|
static class |
KMeans.Centroid
A simple two-dimensional centroid, basically a point with an ID.
|
Modifier and Type | Method and Description |
---|---|
KMeans.Point |
KMeans.Point.add(KMeans.Point other) |
KMeans.Point |
KMeans.Point.div(long val) |
Modifier and Type | Method and Description |
---|---|
Tuple2<Integer,KMeans.Point> |
KMeans.SelectNearestCenter.map(KMeans.Point p) |
Tuple3<Integer,KMeans.Point,Long> |
KMeans.CountAppender.map(Tuple2<Integer,KMeans.Point> t) |
Tuple3<Integer,KMeans.Point,Long> |
KMeans.CentroidAccumulator.reduce(Tuple3<Integer,KMeans.Point,Long> val1,
Tuple3<Integer,KMeans.Point,Long> val2) |
Modifier and Type | Method and Description |
---|---|
KMeans.Point |
KMeans.Point.add(KMeans.Point other) |
double |
KMeans.Point.euclideanDistance(KMeans.Point other) |
Tuple2<Integer,KMeans.Point> |
KMeans.SelectNearestCenter.map(KMeans.Point p) |
Modifier and Type | Method and Description |
---|---|
Tuple3<Integer,KMeans.Point,Long> |
KMeans.CountAppender.map(Tuple2<Integer,KMeans.Point> t) |
KMeans.Centroid |
KMeans.CentroidAverager.map(Tuple3<Integer,KMeans.Point,Long> value) |
Tuple3<Integer,KMeans.Point,Long> |
KMeans.CentroidAccumulator.reduce(Tuple3<Integer,KMeans.Point,Long> val1,
Tuple3<Integer,KMeans.Point,Long> val2) |
Tuple3<Integer,KMeans.Point,Long> |
KMeans.CentroidAccumulator.reduce(Tuple3<Integer,KMeans.Point,Long> val1,
Tuple3<Integer,KMeans.Point,Long> val2) |
Constructor and Description |
---|
Centroid(int id,
KMeans.Point p) |
Modifier and Type | Method and Description |
---|---|
static DataSet<KMeans.Point> |
KMeansData.getDefaultPointDataSet(ExecutionEnvironment env) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.