Spark Worker內部工做原理

Worker Worker是一個基於AKKA Actor 的Actor模型,和Master,Driver,進行通訊的時候 都是經過在receiver方法中進行樣例類的時間匹配,支持Worker同時實現了ActorLogReceive的trait,ActorLogReceive裏面複寫receive方法,對子類暴露出receiveWithLogging方法,worker只須要複寫這個方法就能夠了,這
相關文章
相關標籤/搜索