Re: window join in flink sql

2021-10-28 Thread Leonard Xu 

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  写道：
> 
> 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 mailto:qqib...@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()
> .equalTo()
> .window()
> .apply()
> (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

2021-10-28 Thread Caizhi Weng 
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  于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()
> .equalTo()
> .window()
> .apply()
>
> (
> 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
>

window join in flink sql

2021-10-28 Thread Lu Niu 
Hi, Flink users

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

stream.join(otherStream)
.where()
.equalTo()
.window()
.apply()

(
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