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