The AfterWatermark trigger emits the contents of a window after the watermark passes the end of the window, based on the timestamps attached to the data elements.
If a global window is used, how does watermark work?
4 Matching Annotations
- Apr 2022
-
beam.apache.org beam.apache.org
-
-
After two days,
Where does this two day come from?
-
This code sample sets a time-based trigger for a PCollection, which emits results one minute after the first element in that window has been processed
don't quite understand, come back later
-
In practice, your PCollection's data source determines the watermark, and watermarks can be more precise or complex.
How does the data source determine the watermark?
-