[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972587#comment-15972587
]
ASF GitHub Bot commented on FLINK-6091:
---------------------------------------
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 <chenghe...@gmail.com>
Date: 2017-04-18T08:54:09Z
[FLINK-6091] [table] Implement and turn on retraction for aggregates
----
> Implement and turn on the retraction for aggregates
> ---------------------------------------------------
>
> Key: FLINK-6091
> URL: https://issues.apache.org/jira/browse/FLINK-6091
> Project: Flink
> Issue Type: Sub-task
> Components: Table API & SQL
> Reporter: Shaoxuan Wang
> Assignee: Hequn Cheng
>
> 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).
> Note: Currently, only unbounded groupby generates retraction and it is
> working under unbounded and processing time mode. Hence, retraction is only
> supported for unbounded and processing time aggregations so far. 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.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
