Hi All,
I'm new to Flink but am trying to write an application that processes data
from internet connected sensors.
My problem is as follows:
-Data arrives in the format: [sensor id] [timestamp in seconds] [sensor
value]
-Data can arrive out of order (between sensor IDs) by upto 5 minutes.
-So a
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 eac
