My recollection is as follows:
- the window end time is computed first and that implies the start time. - The
window end times for a event is determined based on alignment with the slide
interval I think this is the relevant code:
https://github.com/apache/storm/blob/v1.2.2/storm-core/src/jvm/org/apache/storm/windowing/WatermarkTimeTriggerPolicy.java#L110-L116
On Monday, December 3, 2018, 10:22:35 PM PST, ChenBo <[email protected]>
wrote:
Hi All, I use storm-core 1.2.2, I am little confuse about storm.
In document, they say "When a watermark is received, all windows up to that
timestamp will be evaluated."
the question, when are the window start timestamp?
Any help is appreciated.Thanks,
ChenBo
