數據轉換必須熟悉的 Operator(算子)

在 Flink 應用程序中，無論你的應用程序是批程序，還是流程序，都是上圖這種模型，有數據源（source），有數據下游（sink），我們寫的應用程序多是對數據源過來的數據做一系列操作，總結如下。 Source: 數據源，Flink 在流處理和批處理上的 source 大概有 4 類：基於本地集合的 source、基於文件的 source、基於網絡套接字的 source、自定義的 source。自

>>阅读原文<<