public class CountPartitionFunction<IN> extends RichMapPartitionFunction<IN,scala.Tuple2<Object,Object>>
Constructor and Description |
---|
CountPartitionFunction() |
Modifier and Type | Method and Description |
---|---|
void |
mapPartition(Iterable<IN> value,
Collector<scala.Tuple2<Object,Object>> out)
A user-implemented function that modifies or transforms an incoming object.
|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public void mapPartition(Iterable<IN> value, Collector<scala.Tuple2<Object,Object>> out)
MapPartitionFunction
mapPartition
in interface MapPartitionFunction<IN,scala.Tuple2<Object,Object>>
mapPartition
in class RichMapPartitionFunction<IN,scala.Tuple2<Object,Object>>
value
- All records for the mapperout
- The collector to hand results to.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.