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 between your request and re
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")
.window(EventTimeSessionWindows.withGap(Time.mi
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
reque
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
".keyBy("ReqRespID").timeWindowAll(Tim
