Class IntactPartitioner
- java.lang.Object
-
- org.apache.nemo.common.partitioner.IntactPartitioner
-
- All Implemented Interfaces:
Partitioner<Integer>
public final class IntactPartitioner extends Object implements Partitioner<Integer>
An implementation ofPartitioner
which makes an output data from a source task to a single partition.
-
-
Constructor Summary
Constructors Constructor Description IntactPartitioner()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Integer
partition(Object element)
Divides the output data from a task into multiple blocks.
-
-
-
Method Detail
-
partition
public Integer partition(Object element)
Description copied from interface:Partitioner
Divides the output data from a task into multiple blocks.- Specified by:
partition
in interfacePartitioner<Integer>
- Parameters:
element
- the output element from a source task.- Returns:
- the key of the partition in the block to write the element.
-
-