大数据Flink 基于API的双流join FlinkAPI的join方式 使用Flink API要做双流join的话,flink提供了两种方式,一种是基于窗口的window join和基于状态的lnterval join Flink Join算子有非常严厉的限制,就是必须基于时间 通过API实现双流join有个弊端,就是... 4周前 (01-02) 83℃ 0喜欢
大数据Flink 多流转换分流合流 介绍 在Flink中无论是基本的简单转换和聚合,还是基于窗口的计算,我们都是针对一条流上的数据进行处理的。而在实际应用中,可能需要将不同来源的数据连接合并在一起处理,也有可能需要将一条流拆分开,所以经常会有对多条流进行处理的场景。 简单划分的话,多流转换可以分为“分流”和“合流”... 4周前 (01-02) 71℃ 0喜欢