IN
- The original data type.public class AssignRangeIndex<IN> extends RichMapPartitionFunction<IN,Tuple2<Integer,IN>>
Constructor and Description |
---|
AssignRangeIndex(TypeComparatorFactory<IN> typeComparator) |
Modifier and Type | Method and Description |
---|---|
void |
mapPartition(Iterable<IN> values,
Collector<Tuple2<Integer,IN>> out)
A user-implemented function that modifies or transforms an incoming object.
|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public AssignRangeIndex(TypeComparatorFactory<IN> typeComparator)
public void mapPartition(Iterable<IN> values, Collector<Tuple2<Integer,IN>> out) throws Exception
MapPartitionFunction
mapPartition
in interface MapPartitionFunction<IN,Tuple2<Integer,IN>>
mapPartition
in class RichMapPartitionFunction<IN,Tuple2<Integer,IN>>
values
- All records for the mapperout
- The collector to hand results to.Exception
- This method may throw exceptions. Throwing an exception will cause the
operation to fail and may trigger recovery.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.