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