@Public public interface WatermarkGenerator<T>
WatermarkGeneratorgenerates watermarks either based on events or periodically (in a fixed interval).
Note: This WatermarkGenerator subsumes the previous distinction between the
AssignerWithPunctuatedWatermarks and the
|Modifier and Type||Method and Description|
Called for every event, allows the watermark generator to examine and remember the event timestamps, or to emit a watermark based on the event itself.
Called periodically, and might emit a new watermark, or not.
void onEvent(T event, long eventTimestamp, WatermarkOutput output)
void onPeriodicEmit(WatermarkOutput output)
The interval in which this method is called and Watermarks are generated depends on
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.