flink常用算子介紹

Flink中的算子是將一個或多個DataStream轉換爲新的DataStream，可以將多個轉換組合成複雜的數據流拓撲。 在Flink中，有多種不同的DataStream類型，他們之間是使用各種算子進行的。如下圖所示：   flink中常用的算子 map DataStream --> DataStream：輸入一個參數產生一個參數，map的功能是對輸入的參數進行轉換操作。 flatMap Dat

>>阅读原文<<