Re: interval join 如何用 process time

2021-03-24 文章 Smile 
你好，DataStream API 中的 Interval Join 目前还不支持 process time，参考 [1].
不过如果不要去严格准确的 process time 的话，是否可以在 Join 之前把 process time 用某个字段带出来，当 event
time 用？

[1].
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/stream/operators/joining.html#interval-join



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: interval join 如何用 process time

2021-03-17 文章 guomuhua 
你说的这个语法是flink sql 吧，我想问的是stream api 里面怎么用



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: interval join 如何用 process time

2021-03-17 文章 JasonLee 
hi

proctime as PROCTIME() 可以这样设置



-
Best Wishes
JasonLee
--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: interval join 如何用 process time

2021-03-17 文章 HunterXHunter 
你不定义watermark好像用的就是pro time



--
Sent from: http://apache-flink.147419.n8.nabble.com/

interval join 如何用 process time

2021-03-17 文章 guomuhua 
在 flink sql 中，可以使用 proc time 来进行 interval join，但是在 stream api 中，只能用 event
time 进行 interval join，如何能使用 process time 呢？



--
Sent from: http://apache-flink.147419.n8.nabble.com/