GitHub user hequn8128 opened a pull request:
https://github.com/apache/flink/pull/3733
[FLINK-6091] [table] Implement and turn on retraction for aggregates
Implement functions for generating and consuming retract messages for
different aggregates.
1. add delete/add property to Row
2. implement functions for generating retract messages for unbounded groupBy
3. implement functions for handling retract messages for different
aggregates.
4. handle retraction messages in `CommonCorrelate` and `CommonCalc` (retain
Delete property).
Currently, only unbounded groupby generates retraction and it is working
under unbounded and processing time mode. Hence, so far retraction is only
supported for unbounded and processing time aggregations. We can add more
retraction support later.
supported now: unbounded groupby, unbounded and processing time over window
unsupported now: group window, event time or bounded over window.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hequn8128/flink FLINK-6091-PR
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3733.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 #3733
----
commit 911e4516d3d5a17354c75d67e73153aa9194212b
Author: Hequn Cheng <[email protected]>
Date: 2017-04-18T08:54:09Z
[FLINK-6091] [table] Implement and turn on retraction for aggregates
----
---
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.
---
