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 very useful feature, Agree wi
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 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 sugges
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 that Jira issue?
>
> Btw,
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 wrote:
>
> I have a us
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 h
