Apache Flink 漫谈系列 - JOIN 算子
发布时间：2018-11-20 20:07:11 所属栏目：教程 来源：孙金城
导读：聊什么 在《Apache Flink 漫谈系列 - SQL概览》中我们介绍了JOIN算子的语义和基本的使用方式，介绍过程中大家发现Apache Flink在语法语义上是遵循ANSI-SQL标准的，那么再深思一下传统数据库为啥需要有JOIN算子呢?在实现原理上面Apache Flink内部实现和传统
|
上面我们介绍了双流JOIN会使用State记录左右两边流的事件，同时我们示例数据的场景也是比较简单，比如流上没有更新事件(没有撤回事件)，同时流上没有重复行事件。那么我们尝试思考下面的事件流在双流JOIN时候是怎么处理的?
上图示例是连续产生了2笔销售数量一样的订单，同时在产生一笔销售数量为5的订单之后，又将该订单取消了(或者退货了)，这样在事件流上面就会是上图的示意，这种情况Blink内部如何支撑呢? （编辑：核心网） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |
