flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Shaoxuan Wang (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-6090) Implement optimizer for retraction and turn on retraction for over window aggregate
Date Fri, 17 Mar 2017 04:00:43 GMT
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)

Mime
View raw message