flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Paul Joireman <paul.joire...@physiq.com>
Subject Watermarks and window firing
Date Mon, 24 Oct 2016 14:56:35 GMT
Hi all,

The documentation for event timestamps and watermarks (https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/event_timestamps_watermarks.html)
states that the

The AssignerWithPeriodicWatermarks assigns timestamps and generates watermarks periodically
(possibly depending on the stream elements, or purely based on processing time).

The interval (every n milliseconds) in which the watermark will be generated is defined viaExecutionConfig.setAutoWatermarkInterval(...).
Each time, the assigner's getCurrentWatermark() method will be called, and a new Watermark
will be emitted, if the returned Watermark is non-null and larger than the previous Watermark.

View raw message