[
https://issues.apache.org/jira/browse/FLINK-22714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andy updated FLINK-22714:
-------------------------
Description:
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.
was:
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.
> 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
> 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)
