org.apache.storm.hdfs.trident.format
Interface FileNameFormat
- All Superinterfaces:
- Serializable
- All Known Implementing Classes:
- DefaultFileNameFormat
public interface FileNameFormat
- extends Serializable
Formatter interface for determining HDFS file names.
Method Summary |
String |
getName(long rotation,
long timeStamp)
Returns the filename the HdfsBolt will create. |
String |
getPath()
|
void |
prepare(Map conf,
int partitionIndex,
int numPartitions)
|
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()
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.