Package org.apache.storm.hdfs.common
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:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description NullPartitioner()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getPartitionPath(Tuple tuple)
Return a relative path that the tuple should be written to.
-
-
-
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 interfacePartitioner
- Parameters:
tuple
- The tuple for which the relative path is being calculated.
-
-