[jira] [Created] (FLINK-11959) Introduce window operator for blink streaming runtime

[Shang Yuanchun (Jira)]

Kurt Young created FLINK-11959:
----------------------------------

             Summary: Introduce window operator for blink streaming runtime
                 Key: FLINK-11959
                 URL: https://issues.apache.org/jira/browse/FLINK-11959
             Project: Flink
          Issue Type: New Feature
          Components: Runtime / Operators
            Reporter: Kurt Young
            Assignee: Kurt Young


We introduced a new window operator in blink streaming runtime, the differences between blink's window operator and the one used in DataStream API are:
 # The blink's window operator is mainly used by window aggregate. It work closely with SQL's aggregate function, hence we didn't provide the flexibility to apply arbitrary `WindowFunction` like DataStream did. Instead, we only need to save the intermediate accumulate state for aggregate functions. There is no need for us to save original input rows into state, which will be much more efficient.
 # This new window operator can deal with retract messages.
 # We did some pane based optimization within sliding window operator, similar with [FLINK-7001|https://issues.apache.org/jira/browse/FLINK-7001]. 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)