Hi all, I have a kafka stream of events with a field that says "up" or "down". If a particular key has been "down" for the last 10 minutes emit an event. I was thinking I could use session windows and when we receive an "up" event start a new window for "down" events. Having some trouble figuring out how to chain this. I think I would use a custom trigger, IE when event "up" process the window. But how do I define the window size? Even if it was a dynamic window size, not sure how I can do that. Any guidance would be appreciated.