有些时候需要实现对单个流拆分为多个流的操作,这就要用到 Split 或者 Side Output API 了。

Split

<aside> 💡 通过 Split 接口,相当于是对数据的一个筛选过程,其处理前后的数据类型需要一致

</aside>

Side Output

<aside> 💡 Side Output 前后数据类型可以不一致

</aside>