interval join 如何用 process time

[guomuhua]

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



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

[HunterXHunter]

你不定义watermark好像用的就是pro time



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

[JasonLee]

hi

proctime as PROCTIME() 可以这样设置



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

[guomuhua]

你说的这个语法是flink sql 吧，我想问的是stream api 里面怎么用



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

[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/