Re: Sliding window based on event arrival

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

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

Sliding window based on event arrival

Hi, I need to create a sliding window of 4 events in Flink streaming application. The window should slide by one event per every new arriving event. Furthermore, per each new arriving event I need to calculate the aggregate sum of a particular field in the 4 events I have in the window. I have r