Class NullPartitioner

java.lang.Object
org.apache.storm.hdfs.common.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:
  • Constructor Details

    • NullPartitioner

      public NullPartitioner()
  • Method Details

    • 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.