[jira] [Created] (FLINK-22714) Simplify `StreamPhysicalWindowTableFunction` to `StreamPhysicalWindowAssignerFunction` which is only a simple window assigner table function if successor node with `WindowAttachedWindowingStrategy` in planner

[Shang Yuanchun (Jira)]

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)