Re: Dynamic SessionWindow gaps

2018-01-12 Thread dyana.r...@salecycle.com
I've put up some implementation information and a link to the working branch for comment while I get the documentation written up: https://issues.apache.org/jira/browse/FLINK-8384 Thanks, Dyana On 2018-01-02 13:54, jincheng sun wrote: > Hi, Dyana dynamic gap is

Re: Dynamic SessionWindow gaps

2018-01-02 Thread jincheng sun
Hi, Dyana dynamic gap is very useful feature, Agree with the suggestion of Aljoscha, looking forward the PR. Best, Jincheng 2018-01-02 21:45 GMT+08:00 Aljoscha Krettek : > Hi, > > This sounds good! Could you please open a Jira Issue for this and then > open a PR against

Re: Dynamic SessionWindow gaps

2018-01-02 Thread Aljoscha Krettek
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

Dynamic SessionWindow gaps

2017-12-29 Thread Dyana Rose
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