Hi Till,
thank you for your reply.
This is exactly what I was looking for!
Flink continues to surprise me with its versatility. :)
Best Regards,
Julian
2016-11-07 16:47 GMT+01:00 Till Rohrmann :
> Hi Julian,
>
> you can use the TriggerContext to register and unregister event time
> timers whi
Hi Julian,
you can use the TriggerContext to register and unregister event time timers
which fire when the given event time has been passed. That’s one way to
implement what you’ve described. If you don’t want to use time windows you
could also use session windows. Take a look at the EventTimeSess
Hello everybody,
I'm currently trying to implement a Function that allows me to detect that
a certain amount of time has passed after receiving the last element of a
stream (in a given time window). For example if nothing happened for 6
hours within a given Session I want to do something (set a fl
