Re: maxtime / watermark for GlobaWindow

2016-01-26 Thread Till Rohrmann
Hi Radu, If I’m not mistaken, then it’s not possible with the current GlobalWindow implementation. However, you could extend the GlobalWindow which adds a new field into which the timestamp of the triggering element is stored. This field can then be read from within the WindowFunction to retrieve

maxtime / watermark for GlobaWindow

2016-01-25 Thread Radu Tudoran
Hi, I am using a global window to collect some events. I use a trigger to fire the processing. Is there any way to get the time of the event that has triggered the processing. I am asking this as the getMaxTime() field of the GlobalWindow returns MaxLong. The code skeleton is: stream .