Package org.apache.storm.hdfs.common
Interface Partitioner
- All Superinterfaces:
Serializable
- All Known Implementing Classes:
NullPartitioner
-
Method Summary
Modifier and TypeMethodDescriptiongetPartitionPath
(Tuple tuple) Return a relative path that the tuple should be written to.
-
Method Details
-
getPartitionPath
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.
-