[spark streaming]Receiver數據接收全過程詳解

一、Receiver啓動過程回顧 如圖,從ReceiverTracker的start方法開始,調用launchReceivers()方法,給endpoint發送消息,endpoint.send(StartAllReceivers(receivers)),endpoint就是ReceiverTrackerEndpoint,ReceiverTrackerEndpoint調用startReceiver方
相關文章
相關標籤/搜索