org.apache.storm.hdfs.trident.format

Interface FileNameFormat

All Superinterfaces:

Serializable

All Known Implementing Classes:

DefaultFileNameFormat, SimpleFileNameFormat

public interface FileNameFormat
extends Serializable

Formatter interface for determining HDFS file names.

Method Summary

Modifier and Type	Method and Description
String	getName(long rotation, long timeStamp) Returns the filename the HdfsBolt will create.
String	getPath()
void	prepare(Map conf, int partitionIndex, int numPartitions)

Method Detail

prepare

void prepare(Map conf,
             int partitionIndex,
             int numPartitions)

getName

String getName(long rotation,
               long timeStamp)

Returns the filename the HdfsBolt will create.

Parameters:

rotation - the current file rotation number (incremented on every rotation)

timeStamp - current time in milliseconds when the rotation occurs

Returns:

getPath

String getPath()