spark之master與worker通信模型講解

通信模型架構圖 master 端代碼 import akka.actor.{Actor, ActorSystem, Props} import com.typesafe.config.ConfigFactory // 需要導入這2個包 封裝一些屬性。 class MasterActor extends Actor {   //在開始之前調用一次   override def preStart()

>>阅读原文<<