Interface Collector<OUT>

    • Method Detail

      • collect

        void collect​(OUT record)
        Collect record to output stream.
        Parameters:
        record - to be collected.
      • collectAndOverwriteTimestamp

        void collectAndOverwriteTimestamp​(OUT record,
                                          long timestamp)
        Overwrite the timestamp of this record and collect it to output stream.
        Parameters:
        record - to be collected.
        timestamp - of the processed data.