GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/3364
[FLINK-5047] [table] Add sliding group-windows for batch tables
This PR implements sliding group-windows. It covers the following cases:
- Grouped Slide count-windows with incremental aggregates
- Grouped and All Slide time-windows with incremental and non-incremental
aggregates
All windows support the overlapping and non-overlapping case. Slide windows
are pre-tumbled if possible. This PR also fixes some bugs.
If the general design is ok, I will also implement the missing
non-incremental aggregates for count-windows. And add a bit of documentation.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/twalthr/flink FLINK-5047
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3364.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3364
----
commit adcedd91e76e73457740816f691ccf64f2e2e38b
Author: twalthr <[email protected]>
Date: 2017-01-18T15:56:02Z
[FLINK-5047] [table] Add sliding group-windows for batch tables
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
