Package org.apache.storm.hdfs.trident.format

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

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. use withTimeFormat to format. $NUM - rotation number $HOST - local host name $PARTITION - partition index
SimpleFileNameFormat	withPath(String path)
SimpleFileNameFormat	withTimeFormat(String timeFormat)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SimpleFileNameFormat

public SimpleFileNameFormat()

Method Details

getName

public String getName(long rotation,
 long timeStamp)

Description copied from interface: FileNameFormat

Returns the filename the HdfsBolt will create.

Specified by:

getName in interface FileNameFormat

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 interface FileNameFormat

prepare

public void prepare(Map<String,Object> conf,
 int partitionIndex,
 int numPartitions)

Specified by:

prepare in interface FileNameFormat

withPath

public SimpleFileNameFormat withPath(String path)

withName

public SimpleFileNameFormat withName(String name)

support parameters:
$TIME - current time. use withTimeFormat to format.
$NUM - rotation number
$HOST - local host name
$PARTITION - partition index

Parameters:

name - file name

withTimeFormat

public SimpleFileNameFormat withTimeFormat(String timeFormat)