Apache Flink源碼解析之stream-transformation

以前咱們聊了Flink程序的source、sink就差transformation了。今天咱們就來解讀一下Flink的transformation。它們三者的關係以下圖：web 固然這仍是從Flink編程API的角度來看的（編程視角）。所謂的transformation，用於轉換一個或多個DataStream從而造成一個新的DataStream對象。Flink提供編程接口，容許你組合這些trans

>>阅读原文<<