SparkStreaming 使用

Spark Streaming 架構: 1,Spark Streaming爲每個輸入源啓動對應的接收器。接收器以任務的形式運行在應用的執行器進程中,從輸入源收集數據並保存爲 RDD。 2,收集到輸入數據後會把數據複製到另一個執行器進程來保障容錯性(默 認行爲)。數據保存在執行器進程的內存中,和緩存 RDD 的方式一樣。 3,驅動器程序中的 StreamingContext
相關文章
相關標籤/搜索