Interface FileNameFormat

    • Method Detail

      • prepare

        void prepare​(Map<String,​Object> 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