Class IntactPartitioner

  • All Implemented Interfaces:
    Partitioner<java.lang.Integer>

    public final class IntactPartitioner
    extends java.lang.Object
    implements Partitioner<java.lang.Integer>
    An implementation of Partitioner which makes an output data from a source task to a single partition.
    • 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.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • IntactPartitioner

        public IntactPartitioner()
    • 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 interface Partitioner<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.