Class SimpleFileNameFormat

java.lang.Object
org.apache.storm.hdfs.bolt.format.SimpleFileNameFormat
All Implemented Interfaces:
Serializable, FileNameFormat

public class SimpleFileNameFormat extends Object implements FileNameFormat
See Also:
  • 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, TopologyContext topologyContext)
      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
      $COMPONENT - component id
      $TASK - task id
      Parameters:
      name - file name
    • withTimeFormat

      public SimpleFileNameFormat withTimeFormat(String timeFormat)