淺談Flink分佈式運行時和數據流圖的並行化

本文將以WordCount的案例爲主線，主要介紹Flink的設計和運行原理。關於Flink WordCount程序可以參考我之前的文章：讀取Kafka實時數據流，實現Flink WordCount。閱讀完本文後，讀者可以對Flink的分佈式運行時有一個全面的認識。 1 Flink數據流圖簡介 1.1 Flink作業的邏輯視圖 在大數據領域，詞頻統計（WordCount）程序就像是一個編程語言的He

>>阅读原文<<