@Public public class AscendingTimestampsWatermarks<T> extends BoundedOutOfOrdernessWatermarks<T>
The current watermark is always one after the latest (highest) timestamp, because we assume that more records with the same timestamp may still follow.
The watermarks are generated periodically and tightly follow the latest timestamp in the data.
The delay introduced by this strategy is mainly the periodic interval in which the watermarks are
generated, which can be configured via
|Constructor and Description|
Creates a new watermark generator with for ascending timestamps.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.