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)