Package org.apache.storm.hdfs.common

Interface Partitioner

All Superinterfaces:
Serializable
All Known Implementing Classes:
NullPartitioner
public interface Partitioner extends Serializable

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    getPartitionPath(Tuple tuple)
    Return a relative path that the tuple should be written to.

  • Method Details

    • getPartitionPath

      String getPartitionPath(Tuple tuple)
      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 "/"

      Parameters:
      tuple - The tuple for which the relative path is being calculated.