flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lofifnc <alexander.k...@mni.thm.de>
Subject Re: Trying to comprehend rolling windows + event time
Date Sat, 20 Feb 2016 16:33:35 GMT
Hi Nirmalya,

The aggregates will be printed 5 times because I have a rolling window with
the length of 5 minutes, which will shift 1 minute forward after each
evaluation. Because my input is within the time interval of 0 to 1 minute,
it is perfectly aligned with the windows and will fit completely into 5
different windows, thus will be evaluated 5 times. 

I have created another gist, where the start and end time of each window is
shown along with it's content.
The single record I'm emitting into the data flow will fit into 5 different
overlapping windows.  
https://gist.github.com/lofifnc/36861d8f37b166cc4863

If you've haven't already read them, I can really recommend the two
articles, Tyler Akidau has published on o'reilly radar, they have some
really great explanations and visualisations in them:
https://www.oreilly.com/people/09f01-tyler-akidau

Best,
Alex







--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Trying-to-comprehend-rolling-windows-event-time-tp5050p5056.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Mime
View raw message