Class WaterMarkEvent<T>

  • All Implemented Interfaces:
    Event<T>

    public class WaterMarkEvent<T>
    extends EventImpl<T>
    Watermark event used for tracking progress of time when processing event based ts.
    • Constructor Detail

      • WaterMarkEvent

        public WaterMarkEvent​(long ts)
    • Method Detail

      • 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>
        Overrides:
        isWatermark in class EventImpl<T>
        Returns:
        true if this is a watermark event