双流join的底层原理

union：union 支持双流 Join，也支持多流 Join。多个流类型必须一致；

connector：connector 支持双流 Join，两个流的类型可以不一致；

join：该方法只支持 inner join，即：相同窗口下，两个流中，Key都存在且相同时才会关联成功；

coGroup：同样能够实现双流 Join。即：将同一 Window 窗口内的两个DataStream 联合起来，两个流按照 Key 来进行关联，并通过 apply()方法 new CoGroupFunction() 的形式，重写 join() 方法进行逻辑处理。

intervalJoin：Interval Join 没有 Window 窗口的概念，直接用时间戳作为关联的条件，更具表达力

©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容