Shaoxuan Wang created FLINK-6090:
------------------------------------
Summary: 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
Reporter: Shaoxuan Wang
Assignee: Shaoxuan Wang
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)
