Class IntactPartitioner

    • Constructor Detail

      • IntactPartitioner

        public IntactPartitioner()
    • 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 interface Partitioner<Integer>
        Parameters:
        element - the output element from a source task.
        Returns:
        the key of the partition in the block to write the element.