Flink SplitStream的簡單使用

Flink SplitStream的簡單使用 在Flink DataStream api中有一個split()算子，它的功能是將一個Stream，經過split()設置多個標記，劃分紅多個流。再經過select()獲取對應標記的流。web 像種算子，能夠根據不一樣的tag，進行不一樣的邏輯處理，可謂是很是的方便。bootstrap 具體看代碼：api public class SplitOpera

>>阅读原文<<