SparkStreaming源碼運行架構圖解

Spark Streaming基本原理：是將流數據分紅小的時間片斷（幾秒），以相似批處理方式來處理這部分小數據。 處理流程：框架 Spark Streaming把實時輸入數據流以時間片Δt （如1秒）爲單位切分紅塊 Spark Streaming會把每塊數據做爲一個RDD，並使用RDD操做處理每一小塊數據 每一個塊都會生成一個Spark Job處理 最終結果也返回多塊 Spark Streamin

>>阅读原文<<