Package org.apache.nemo.common.partitioner
-
Interface Summary Interface Description Partitioner<K extends java.io.Serializable> This interface represents the way of partitioning output data from a source task. -
Class Summary Class Description DedicatedKeyPerElementPartitioner An implementation ofPartitioner
which assigns a dedicated key per an output data from a task.HashPartitioner An implementation ofPartitioner
which hashes output data from a source task according to the key of elements.IntactPartitioner An implementation ofPartitioner
which makes an output data from a source task to a single partition. -
Annotation Types Summary Annotation Type Description DedicatedKeyPerElement Declares that all of the designated keys for each element in aPartitioner
is dedicated for the element.