public static final class KMeans.SelectNearestCenter extends RichMapFunction<KMeans.Point,scala.Tuple2<Object,KMeans.Point>>
Constructor and Description |
---|
SelectNearestCenter() |
Modifier and Type | Method and Description |
---|---|
scala.Tuple2<Object,KMeans.Point> |
map(KMeans.Point p)
The mapping method.
|
void |
open(Configuration parameters)
Reads the centroid values from a broadcast variable into a collection.
|
close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext
public void open(Configuration parameters)
open
in interface RichFunction
open
in class AbstractRichFunction
parameters
- The configuration containing the parameters attached to the contract.Configuration
public scala.Tuple2<Object,KMeans.Point> map(KMeans.Point p)
MapFunction
map
in interface MapFunction<KMeans.Point,scala.Tuple2<Object,KMeans.Point>>
map
in class RichMapFunction<KMeans.Point,scala.Tuple2<Object,KMeans.Point>>
p
- The input value.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.