请问下各位大佬，在flink官网上讲解join的一章里，有这样一张图，在这张图中不太理解的是，为什么0,1 和1,0 也会作为join的结果输出呢？
转自钉钉群21789141：请问下各位大佬，在flink官网上讲解join的一章里，有这样一张图，在这张图中不太理解的是，为什么0,1 和1,0 也会作为join的结果输出呢？
val orangeStream: DataStream[Integer] = ...
val greenStream: DataStream[Integer] = ...
orangeStream.join(greenStream)
.where(elem => /* select key */)
.equalTo(elem => /* select key */)
.window(TumblingEventTimeWindows.of(Time.milliseconds(2)))
.apply { (e1, e2) => e1 + "," + e2 }
展开
收起
1
条回答
写回答
写回答
-
join实现方式是nested-loop join ， 得出的是笛卡儿积。具体到0,1 和1,0。对应的就是第一个窗口内的，。官方文档可以参考这个： https://flink.apache.org/news/2015/03/13/peeking-into-Apache-Flinks-Engine-Room.html
2019-07-17 23:09:59赞同 1 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
