[jira] [Assigned] (FLINK-23749) Testing Window Join

["Timo Walther (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-23749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Timo Walther reassigned FLINK-23749:
------------------------------------

    Assignee: Martijn Visser  (was: lixiaobao)

> 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
>            Assignee: Martijn Visser
>            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].
> {code:java}
> SELECT ...
> FROM L [LEFT|RIGHT|FULL OUTER] JOIN R -- L and R are relations applied windowing TVF
> ON L.window_start = R.window_start AND L.window_end = R.window_end AND ...
> {code}
> 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.
> Currently, Flink not only supports Window Join which follows after [Window Aggregation|https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/sql/queries/window-agg/].  But also supports Window Join which follows after [Windowing TVF|https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/sql/queries/window-tvf/] .



--
This message was sent by Atlassian Jira
(v8.3.4#803005)