Class EventImpl<T>

java.lang.Object
org.apache.storm.windowing.EventImpl<T>
All Implemented Interfaces:
Event<T>
Direct Known Subclasses:
WaterMarkEvent

public class EventImpl<T> extends Object implements Event<T>
  • Method Details

    • getTimestamp

      public long getTimestamp()
      Description copied from interface: Event
      The event timestamp in millis. This could be the time when the source generated the tuple or the time when the tuple was received by a bolt.
      Specified by:
      getTimestamp in interface Event<T>
      Returns:
      the event timestamp in milliseconds.
    • get

      public T get()
      Description copied from interface: Event
      Returns the wrapped object, E.g. a tuple
      Specified by:
      get in interface Event<T>
      Returns:
      the wrapped object.
    • isWatermark

      public boolean isWatermark()
      Description copied from interface: Event
      If this is a watermark event or not. Watermark events are used for tracking time while processing event based ts.
      Specified by:
      isWatermark in interface Event<T>
      Returns:
      true if this is a watermark event
    • toString

      public String toString()
      Overrides:
      toString in class Object