Hi Guowei, Thank you for your reply. Are you able to give some detail on how that would work with the per window state you linked? I'm struggling to see how the logic would work.
I guess something like a session window on a keyed stream (keyed by sensor ID). Timers would fire 90 seconds after each element is added to the window and then be evaluated? I can't quite think how this would work in practise or how to handle the case where timers fire for data that has already been ejected from the window (as it has been matched with past data)? If there are any examples showing similar uses of this function that would be great? Any assistance is very appreciated! Best, Marc -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
