[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang reassigned FLINK-6090:
------------------------------------
Assignee: Hequn Cheng (was: Shaoxuan Wang)
> Implement optimizer for retraction and turn on retraction for over window
> aggregate
> -----------------------------------------------------------------------------------
>
> Key: FLINK-6090
> URL: https://issues.apache.org/jira/browse/FLINK-6090
> Project: Flink
> Issue Type: Sub-task
> Components: Table API & SQL
> Reporter: Shaoxuan Wang
> Assignee: Hequn Cheng
>
> Implement optimizer for retraction and turn on the retraction for over window
> as the first prototype example:
> 1.Add RetractionRule at the stage of decoration，which can derive the
> replace table/append table, NeedRetraction property.
> 2. Match the NeedRetraction and replace table, mark the accumulating mode;
> Add the necessary retract generate function at the replace table, and add the
> retract process logic at the retract consumer
> 3. turn on retraction for over window aggregate
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
