[
https://issues.apache.org/jira/browse/FLINK-11959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11959:
-----------------------------------
Labels: pull-request-available (was: )
> 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: Table SQL / Runtime
> Reporter: Kurt Young
> Assignee: Kurt Young
> Priority: Major
> Labels: pull-request-available
>
> 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)
