[
https://issues.apache.org/jira/browse/FLINK-22714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-22714:
-------------------------------
Assignee: Andy
> Simplify `StreamPhysicalWindowTableFunction` to
> `StreamPhysicalWindowAssignerFunction` which is only a simple window assigner
> table function if successor node with `WindowAttachedWindowingStrategy` in
> planner
> -----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-22714
> URL: https://issues.apache.org/jira/browse/FLINK-22714
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Planner
> Affects Versions: 1.14.0
> Reporter: Andy
> Assignee: Andy
> Priority: Major
>
> In theory, `StreamPhysicalWindowTableFunction` should works as a window
> assigner and emits at ends of window. However,
> `StreamPhysicalWindowTableFunction` could be simplified to a simple window
> assigner, and emits per record if it's successor node is one of
> `WindowRank`/`WindowJoin`/`WindowAggregate` with
> `WindowAttachedWindowingStrategy`, because those nodes would assign input
> records to windows have been assigned in input nodes, and trigger emit at
> ends of window.
> Besides, we should add a limit that window is based on rowtime, because it
> has syntax problem if window is assigned based on the proc-time of previous
> operator.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
