[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-6090:
-------------------------------
Description:
Implement optimizer for retraction:
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
When this task is finished, we can turn on retraction for different operators
according to accumulating mode.
was:
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
> Add RetractionRule at the stage of decoration
> ---------------------------------------------
>
> 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:
> 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
>
> When this task is finished, we can turn on retraction for different operators
> according to accumulating mode.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
