Package org.apache.flink.examples.java.clustering

Class KMeans.SelectNearestCenter

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.api.common.functions.RichMapFunction<KMeans.Point,org.apache.flink.api.java.tuple.Tuple2<Integer,KMeans.Point>>

org.apache.flink.examples.java.clustering.KMeans.SelectNearestCenter

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.MapFunction<KMeans.Point,org.apache.flink.api.java.tuple.Tuple2<Integer,KMeans.Point>>, org.apache.flink.api.common.functions.RichFunction

Enclosing class:

KMeans

public static final class KMeans.SelectNearestCenter
extends org.apache.flink.api.common.functions.RichMapFunction<KMeans.Point,org.apache.flink.api.java.tuple.Tuple2<Integer,KMeans.Point>>

Determines the closest cluster center for a data point.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
SelectNearestCenter()

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.java.tuple.Tuple2<Integer,KMeans.Point>	map(KMeans.Point p)
void	open(org.apache.flink.configuration.Configuration parameters)	Reads the centroid values from a broadcast variable into a collection.

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object

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

Constructor Detail

SelectNearestCenter

public SelectNearestCenter()

Method Detail

open

public void open(org.apache.flink.configuration.Configuration parameters)
          throws Exception

Reads the centroid values from a broadcast variable into a collection.

Specified by:

open in interface org.apache.flink.api.common.functions.RichFunction

Overrides:

open in class org.apache.flink.api.common.functions.AbstractRichFunction

Throws:

Exception

map

public org.apache.flink.api.java.tuple.Tuple2<Integer,KMeans.Point> map(KMeans.Point p)
                                                                       throws Exception

Specified by:

map in interface org.apache.flink.api.common.functions.MapFunction<KMeans.Point,org.apache.flink.api.java.tuple.Tuple2<Integer,KMeans.Point>>

Specified by:

map in class org.apache.flink.api.common.functions.RichMapFunction<KMeans.Point,org.apache.flink.api.java.tuple.Tuple2<Integer,KMeans.Point>>

Throws:

Exception