Class PeriodicWatermarkAssigner

    • Constructor Detail

      • PeriodicWatermarkAssigner

        public PeriodicWatermarkAssigner()
    • Method Detail

      • nextTimestamp

        public abstract void nextTimestamp​(long timestamp)
        Updates the assigner with the next timestamp.
        Parameters:
        timestamp - The next timestamp to update the assigner.
      • getWatermark

        public abstract Watermark getWatermark()
        Returns the current watermark.
        Returns:
        The current watermark.