Class SimpleFileNameFormat
- java.lang.Object
-
- org.apache.storm.hdfs.trident.format.SimpleFileNameFormat
-
- All Implemented Interfaces:
Serializable
,FileNameFormat
public class SimpleFileNameFormat extends Object implements FileNameFormat
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description SimpleFileNameFormat()
-
Method Summary
All Methods Instance Methods Concrete Methods 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)
SimpleFileNameFormat
withName(String name)
support parameters:
$TIME - current time.SimpleFileNameFormat
withPath(String path)
SimpleFileNameFormat
withTimeFormat(String timeFormat)
-
-
-
Method Detail
-
getName
public String getName(long rotation, long timeStamp)
Description copied from interface:FileNameFormat
Returns the filename the HdfsBolt will create.- Specified by:
getName
in interfaceFileNameFormat
- Parameters:
rotation
- the current file rotation number (incremented on every rotation)timeStamp
- current time in milliseconds when the rotation occurs
-
getPath
public String getPath()
- Specified by:
getPath
in interfaceFileNameFormat
-
prepare
public void prepare(Map<String,Object> conf, int partitionIndex, int numPartitions)
- Specified by:
prepare
in interfaceFileNameFormat
-
withPath
public SimpleFileNameFormat withPath(String path)
-
withName
public SimpleFileNameFormat withName(String name)
support parameters:
$TIME - current time. usewithTimeFormat
to format.
$NUM - rotation number
$HOST - local host name
$PARTITION - partition index- Parameters:
name
- file name
-
withTimeFormat
public SimpleFileNameFormat withTimeFormat(String timeFormat)
-
-