[
https://issues.apache.org/jira/browse/FLINK-23749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JING ZHANG updated FLINK-23749:
-------------------------------
Description:
The window join requires the join on condition contains window starts equality
of input tables and window ends equality of input tables. The semantic of
window join is the same to the [DataStream window
join|https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/operators/joining.html#window-join].
In the future, we can also simplify the join on clause to only include the
window start equality if the windowing TVF is {{TUMBLE}} or {{HOP}} .
Currently, the windowing TVFs must be the same of left and right inputs. This
can be extended in the future, for example, tumbling windows join sliding
windows with the same window size.
was:
The window join requires the join on condition contains window starts equality
of input tables and window ends equality of input tables. The semantic of
window join is the same to the [DataStream window
join|https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/operators/joining.html#window-join].
SELECT ...FROM L [LEFT|RIGHT|FULL OUTER] JOIN R -- L and R are relations
applied windowing TVFON L.window_start = R.window_start AND L.window_end =
R.window_end AND ...
In the future, we can also simplify the join on clause to only include the
window start equality if the windowing TVF is {{TUMBLE}} or {{HOP}} .
Currently, the windowing TVFs must be the same of left and right inputs. This
can be extended in the future, for example, tumbling windows join sliding
windows with the same window size.
> Testing Window Join
> -------------------
>
> Key: FLINK-23749
> URL: https://issues.apache.org/jira/browse/FLINK-23749
> Project: Flink
> Issue Type: Improvement
> Components: Tests
> Reporter: JING ZHANG
> Priority: Blocker
> Labels: release-testing
> Fix For: 1.14.0
>
>
> The window join requires the join on condition contains window starts
> equality of input tables and window ends equality of input tables. The
> semantic of window join is the same to the [DataStream window
> join|https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/operators/joining.html#window-join].
> In the future, we can also simplify the join on clause to only include the
> window start equality if the windowing TVF is {{TUMBLE}} or {{HOP}} .
> Currently, the windowing TVFs must be the same of left and right inputs. This
> can be extended in the future, for example, tumbling windows join sliding
> windows with the same window size.
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
