flink 1.12.0版本的interval join 实现应该看哪个地方的源码?-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

flink 1.12.0版本的interval join 实现应该看哪个地方的源码?

游客f3qdfn6ohc63c 2021-02-07 17:28:51 282

是看flink-streaming-java模块的org.apache.flink.streaming.api.operators.co.IntervalJoinOperator?

还是看flink-table-planner模块的org.apache.flink.table.runtime.join.TimeBoundedStreamJoin?

或者是看Blink里面是怎么实现的?我用的plan是Blink,所以想问interval join的实现应该具体看哪个地方的源码

流计算
分享到
取消 提交回答
全部回答(0)

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

推荐文章
相似问题
链接