Re: question regarding windowed stream

2016-05-07 Thread Aljoscha Krettek
Hi, yes, the input does indeed play a role. If not elements are incoming then there will also be no window. Cheers, Aljoscha On Fri, 6 May 2016 at 12:18 Balaji Rajagopalan < balaji.rajagopa...@olacabs.com> wrote: > I have a requirement where I want to do aggregation on one data stream > every 5

question regarding windowed stream

2016-05-06 Thread Balaji Rajagopalan
I have a requirement where I want to do aggregation on one data stream every 5 minutes, a different data stream every 1 minute. I wrote a example code to test this out but the behavior is different from what I expected , I expected the window2 to be called 5 times, and window 1 to called once , but