[jira] [Created] (FLINK-6090) Implement optimizer for retraction and turn on retraction for over window aggregate

[Shang Yuanchun (Jira)]

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)