Flink DataStream Split 实现分流

Posted 2022-09-08 @SmartSi

传送门：Flink 系统性学习笔记

---

在 Flink 1.12.0 版本中进行了删除

所谓分流，就是将一条数据流拆分成完全独立的两条、甚至多条流。也就是基于一个 DataStream 拆分成多个完全平等的子 DataStream。一般来说，我们会定义一些筛选条件，将符合条件的数据拣选出来放到对应的流里。

使用 Split 实现分流需要在 split 算子中定义 OutputSelector，然后重写其中的 select 方法，将不同类型的数据进行标记，最后对返回的 SplitStream 使用 select 方法将对应的数据选择出来。如下所示将输入流拆分为奇数流和偶数流两个子数据流：

final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment()