Flink簡介及環境安裝部署、詞頻統計實例、WordCount源碼分析

Flink 是一個針對流數據和批數據的分佈式處理引擎。它主要是由 Java 代碼實現。 具體見官網介紹，我就很少說了 https://flink.apache.org/ 根據本身hadoop和scala的版本安裝對應版本的Flink 下載好解壓縮到指定目錄，cd進去bin目錄 下面操做具體參考官方文檔快速啓動 https://ci.apache.org/projects/flink/flink-d

>>阅读原文<<