Sounds good, I'm on holiday at the moment. I'll get the ball rolling with a raised issue when I get in.
Dyana On 2018-01-02 13:45, Aljoscha Krettek <[email protected]> wrote: > Hi,> > > This sounds good! Could you please open a Jira Issue for this and then open a PR against that Jira issue?> > > Btw, I would suggest to implement this as a new type of assigner, something like DynamicSessionWindows.> > > Best,> > Aljoscha> > > > On 29. Dec 2017, at 20:54, Dyana Rose <[email protected]> wrote:> > > > > > 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> > >
