Hi, I'd like to create a job that computes session windows from my input source with special behavior. The records I am receiving can explicitly reflect the completion of that session, which should mark the end of that particular window. If I receive another record for the same key 1 second later (regardless of what the session timeout gap is), I'd like for that to create a new window. I see there is an

EventTimeSessionWindows.withDynamicGap

-- is this what I'm looking for, or do I need to play around with the windows/merging behavior itself?