Package 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	Description
String	getName(long rotation, long timeStamp)	Returns the filename the HdfsBolt will create.
String	getPath()
void	prepare(Map<String,Object> conf, int partitionIndex, int numPartitions)

Method Details

prepare

void prepare(Map<String,Object> 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

getPath

String getPath()