I have a use case for non-static Session Window gaps. For example, given a stream of IoT events, each device type could have a different gap, and that gap could change while sessions are in flight.
I didn't want to have to run a stream processor for each potential gap length, not to mention the headache of dealing with changing gaps, so I've implemented a version of SessionWindows that has one major change; in the assignWindows method it passes the element to a method to extract the correct sessionTimeout. (current Flink method for reference: https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/EventTimeSessionWindows.java#L59 ) Preliminary tests show this working as required and I can't be the only person with this type of use case for session windows. Will an issue and PR to add this functionality to the SessionWindow classes be welcome? Dyana
