Re: Aggregate events in time window

Which is of course only available in 1.1-SNAPSHOT or the upcoming 1.1 release. :-) On Tue, 19 Jul 2016 at 22:32 Till Rohrmann wrote: > Hi Dominique, > > your problem sounds like a good use case for session windows [1, 2]. If > you know that there is only a maximum gap

Re: Aggregate events in time window

Hi Dominique, your problem sounds like a good use case for session windows [1, 2]. If you know that there is only a maximum gap between your request and response message, then you could create a session window via: input .keyBy("ReqRespID")

Re: Aggregate events in time window

How about using EventTime windows with watermark assignment and bounded delays. That way you allow more than 5 minutes (bounded delay) for your request and responses to arrive. Do you have a way to assign timestamp to the responses based on the request timestamp (does the response contain the

Aggregate events in time window

Hi all, once again I need a "kick" to the right direction. I have a datastream with request and responses identified by an ReqResp-ID. I like to calculate the (avg, 95%, 99%) time between the request and response and also like to count them. I thought of