101、Spark Streaming之數據接收原理剖析與源碼分析

流程圖 數據接收原理剖析.png 源碼剖析 入口包org.apache.spark.streaming.receiver下ReceiverSupervisorImpl類的onStart()方法 override protected def onStart() { // 這裏的blockGenerator很重要，和數據接收有關，其運行在worker的executor端負責數據接收後的一些存取

>>阅读原文<<