@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
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.