@Public public class BoundedOutOfOrdernessWatermarks<T> extends Object implements WatermarkGenerator<T>
T - Bwill follow any more.
The watermarks are generated periodically. The delay introduced by this watermark strategy is the periodic interval length, plus the out-of-orderness bound.
|Constructor and Description|
Creates a new watermark generator with the given out-of-orderness bound.
|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.
public BoundedOutOfOrdernessWatermarks(java.time.Duration maxOutOfOrderness)
maxOutOfOrderness- The bound for the out-of-orderness of the event timestamps.
public void onEvent(T event, long eventTimestamp, WatermarkOutput output)
public void onPeriodicEmit(WatermarkOutput output)
The interval in which this method is called and Watermarks are generated depends on
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.