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:

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/