You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Lu Niu <qq...@gmail.com> on 2021/10/28 18:11:40 UTC

window join in flink sql

Hi, Flink users

How to express multiple stream window join in flink sql? in datastream api,
that's

stream.join(otherStream)
    .where(<KeySelector>)
    .equalTo(<KeySelector>)
    .window(<WindowAssigner>)
    .apply(<JoinFunction>)

(
https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/datastream/operators/joining/
)

For example, in flinksql, how to join two streams in tumbling window and
evaluate a udf joinFunction?

Best
Lu

Re: window join in flink sql

Posted by Leonard Xu <xb...@gmail.com>.

Tips: 

The documentation in  https://ci.apache.org/projects/flink <https://ci.apache.org/projects/flink> is no longer updated any more,
The new documentation site is https://nightlies.apache.org/flink/ <https://nightlies.apache.org/flink/> , please use the new one.

Best,
Leonard


> 在 2021年10月29日，10:41，Caizhi Weng <ts...@gmail.com> 写道：
> 
> Hi!
> 
> Window join in Flink SQL is supported since Flink 1.14, see document [1].
> 
> [1] https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/table/sql/queries/window-join/ <https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/table/sql/queries/window-join/>
> Lu Niu <qqibrow@gmail.com <ma...@gmail.com>> 于2021年10月29日周五 上午2:12写道：
> Hi, Flink users
> 
> How to express multiple stream window join in flink sql? in datastream api, that's
> stream.join(otherStream)
>     .where(<KeySelector>)
>     .equalTo(<KeySelector>)
>     .window(<WindowAssigner>)
>     .apply(<JoinFunction>)
> (https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/datastream/operators/joining/ <https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/datastream/operators/joining/> ) 
> 
> For example, in flinksql, how to join two streams in tumbling window and evaluate a udf joinFunction? 
> 
> Best
> Lu

Re: window join in flink sql

Posted by Caizhi Weng <ts...@gmail.com>.

Hi!

Window join in Flink SQL is supported since Flink 1.14, see document [1].

[1]
https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/table/sql/queries/window-join/

Lu Niu <qq...@gmail.com> 于2021年10月29日周五 上午2:12写道：

> Hi, Flink users
>
> How to express multiple stream window join in flink sql? in datastream
> api, that's
>
> stream.join(otherStream)
>     .where(<KeySelector>)
>     .equalTo(<KeySelector>)
>     .window(<WindowAssigner>)
>     .apply(<JoinFunction>)
>
> (
> https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/datastream/operators/joining/
> )
>
> For example, in flinksql, how to join two streams in tumbling window and
> evaluate a udf joinFunction?
>
> Best
> Lu
>