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