public interface FileNameFormat extends Serializable
Formatter interface for determining HDFS file names.
Modifier and Type | Method and Description |
---|---|
String |
getName(long rotation,
long timeStamp)
Returns the filename the HdfsBolt will create.
|
String |
getPath() |
void |
prepare(Map<String,Object> conf,
TopologyContext topologyContext) |
void prepare(Map<String,Object> conf, TopologyContext topologyContext)
String getName(long rotation, long timeStamp)
Returns the filename the HdfsBolt will create.
rotation
- the current file rotation number (incremented on every rotation)timeStamp
- current time in milliseconds when the rotation occursString getPath()
Copyright © 2020 The Apache Software Foundation. All rights reserved.