If I chain two windows, what event-time would the second window have?
Posted by
Yassin Marzouki on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/If-I-chain-two-windows-what-event-time-would-the-second-window-have-tp8160.html
Hi all,
Say I assign timestamps to a stream and then apply a transformation like this:
stream.keyBy(0).timeWindow(Time.hours(5)).reduce(count).timeWindowAll(Time.days(1)).apply(transformation)
Now, when the first window is applied, events are aggregated based on their timestamps, but I don't understand what timestamp will be assigned to the aggregated result of the reduce operation for the second window to process it. Could you please explain it? Thank you.
Best,
Yassine