Flink實戰(三) - 編程範式及核心概念

1 基本的 API 概念 Flink程序是實現分佈式集合轉換的常規程序（例如，過濾，映射，更新狀態，加入，分組，定義窗口，聚合）。最初從源建立集合（例如，經過從文件，kafka主題或從本地的內存集合中讀取）。結果經過接收器返回，接收器能夠例如將數據寫入（分佈式）文件或標準輸出（例如，命令行終端）。 Flink程序能夠在各類環境中運行，獨立運行或嵌入其餘程序中。執行能夠在本地JVM中執行，也能夠在許

>>阅读原文<<