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 <mrchenbo@qq.com> 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
|