AscendingTimestampsWatermarks (Flink : Core 1.20.2-cp1 API)

java.lang.Object
- org.apache.flink.api.common.eventtime.BoundedOutOfOrdernessWatermarks<T>
- - org.apache.flink.api.common.eventtime.AscendingTimestampsWatermarks<T>

All Implemented Interfaces:

WatermarkGenerator<T>
```
@Public
public class AscendingTimestampsWatermarks<T>
extends BoundedOutOfOrdernessWatermarks<T>
```
A watermark generator that assumes monotonically ascending timestamps within the stream split and periodically generates watermarks based on that assumption.
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 ExecutionConfig.setAutoWatermarkInterval(long).

- Constructor Summary
  
  Constructors
  Constructor Description
  
  AscendingTimestampsWatermarks()
  Creates a new watermark generator with for ascending timestamps.
- Method Summary
  - Methods inherited from class org.apache.flink.api.common.eventtime.BoundedOutOfOrdernessWatermarks
    onEvent, onPeriodicEmit
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - AscendingTimestampsWatermarks
```
public AscendingTimestampsWatermarks()
```
    Creates a new watermark generator with for ascending timestamps.