You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by guomuhua <66...@qq.com> on 2021/03/17 09:59:23 UTC
interval join 如何用 process time
在 flink sql 中，可以使用 proc time 来进行 interval join，但是在 stream api 中，只能用 event
time 进行 interval join，如何能使用 process time 呢？
--
Sent from: http://apache-flink.147419.n8.nabble.com/
Re: interval join 如何用 process time
Posted by HunterXHunter <13...@qq.com>.
你不定义watermark好像用的就是pro time
--
Sent from: http://apache-flink.147419.n8.nabble.com/
Re: interval join 如何用 process time
Posted by Smile <LE...@163.com>.
你好，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
Posted by guomuhua <66...@qq.com>.
你说的这个语法是flink sql 吧，我想问的是stream api 里面怎么用
--
Sent from: http://apache-flink.147419.n8.nabble.com/
Re: interval join 如何用 process time
Posted by JasonLee <17...@163.com>.
hi
proctime as PROCTIME() 可以这样设置
-----
Best Wishes
JasonLee
--
Sent from: http://apache-flink.147419.n8.nabble.com/