Andy created FLINK-22714:
----------------------------
Summary: 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
In theory, `StreamPhysicalWindowTableFunction` should works as a window
assigner and t emit at ends of window. However,
`StreamPhysicalWindowTableFunction` could be simplified to a simple window
assigner, and emit per record if it's successor node are
`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 before WindowJoin.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
