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
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
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
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