SparkStreaming從啓動Receiver到收取數據生成RDD的代碼淺析

前面一片文章介紹了SocketTextStream 是如何從blockmanager裏面獲取block組成blockRDD的, 地址: http://humingminghz.iteye.com/admin/blogs/2310003 那麼接下來關注一下block是怎麼存到blockmanager裏面的。 仍是從receiverTracker.start() 入手, 會執行ReceiverTrac
相關文章
相關標籤/搜索