Re: Sliding window based on event arrival

2018-03-12 Thread Miyuru Dayarathna
Hi Xingcan, Thanks for the clarification. I was able to implement the scenario with the example you provided. Thanks,Miyuru On Monday, 12 March 2018, 12:53, Xingcan Cui wrote: Hi Miyuru, what you need should be something like a `SlidingCountWindow`. Flink Datastream API has already pr

Re: Sliding window based on event arrival

2018-03-12 Thread Xingcan Cui
Hi Miyuru, what you need should be something like a `SlidingCountWindow`. Flink Datastream API has already provided a `countWindow()` method for that and a related example can be found here