Class NullPartitioner

  • All Implemented Interfaces:
    Serializable, Partitioner

    public class NullPartitioner
    extends Object
    implements Partitioner
    The NullPartitioner partitions every tuple to the empty string. In otherwords, no partition sub directories will be added to the path.
    See Also:
    Serialized Form
    • Constructor Detail

      • NullPartitioner

        public NullPartitioner()
    • Method Detail

      • getPartitionPath

        public String getPartitionPath​(Tuple tuple)
        Description copied from interface: Partitioner
        Return a relative path that the tuple should be written to. For example, if an HdfsBolt were configured to write to /common/output and a partitioner returned "/foo" then the bolt should open a file in "/common/output/foo"

        A best practice is to use Path.SEPARATOR instead of a literal "/"

        Specified by:
        getPartitionPath in interface Partitioner
        Parameters:
        tuple - The tuple for which the relative path is being calculated.