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 and Description
String	getPartitionPath(Tuple tuple) Return a relative path that the tuple should be written to.

Method Detail

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.