Class IntactPartitioner
- java.lang.Object
-
- org.apache.nemo.common.partitioner.IntactPartitioner
-
- All Implemented Interfaces:
Partitioner<java.lang.Integer>
public final class IntactPartitioner extends java.lang.Object implements Partitioner<java.lang.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 java.lang.Integer
partition(java.lang.Object element)
Divides the output data from a task into multiple blocks.
-
-
-
Method Detail
-
partition
public java.lang.Integer partition(java.lang.Object element)
Description copied from interface:Partitioner
Divides the output data from a task into multiple blocks.- Specified by:
partition
in interfacePartitioner<java.lang.Integer>
- Parameters:
element
- the output element from a source task.- Returns:
- the key of the partition in the block to write the element.
-
-