Hello! I'm trying to figure out how to implement a window that will emit events at regular intervals or when a specific event is encountered.
A bit of background. I have a stream of events from devices that will send events to our system whenever a user watches a video. These events include a unique id (sessionId) shared by all events of the same same session so I want to key my stream on this. After that I want to aggregate all the events into a session summary and this summary I want to emit every 5 minutes however I still want to keep the summary in the window (in case more events for that session arrives). However if I were to receive an end event (sent by the device once a user stops watching the video) I want to emit the summary and remove it from the window. Is it possible to do this with one of the existing windows together with a trigger or in some other way? Been trying to figure it out by reading the docs but haven't gotten any wiser so turning to the mailing list for help. Best regards, Tim