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)
阿里云实时计算Flink
+ 订阅

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

推荐文章
展开
相似问题
展开
推荐课程
链接