Package com.scaleoutsoftware.collections.timewindowing

Interface WatermarkGenerator

All Known Implementing Classes:
DefaultWatermarkGenerator, LatenessToleranceWatermarkGenerator
public interface WatermarkGenerator
The watermark generator is used to generate a watermark for the last seen event time.

  • Method Summary

    Modifier and Type
    Method
    Description
    long
    generateWatermark(long lastEventTimestampMs)
    Generate (or return the existing) watermark for the last seen event timestamp.

  • Method Details

    • generateWatermark

      long generateWatermark(long lastEventTimestampMs)
      Generate (or return the existing) watermark for the last seen event timestamp.
      Parameters:
      lastEventTimestampMs - the last seen event timestamp.
      Returns:
      the existing or new watermark for this windowing collection.