org.apache.flink.api.common.eventtime

Class AscendingTimestampsWatermarks<T>

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 and 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.