Package org.apache.storm.windowing

Interface TimestampExtractor

All Superinterfaces:
Serializable
All Known Implementing Classes:
TupleFieldTimestampExtractor
public interface TimestampExtractor extends Serializable
Interface to be implemented for extracting timestamp from a tuple.

  • Method Summary

    Modifier and Type
    Method
    Description
    long
    extractTimestamp(Tuple tuple)
    Return the tuple timestamp indicating the time when the event happened.

  • Method Details

    • extractTimestamp

      long extractTimestamp(Tuple tuple)
      Return the tuple timestamp indicating the time when the event happened.
      Parameters:
      tuple - the tuple
      Returns:
      the timestamp