Spark的內置RPC通信框架

spark2.x.x後使用Netty替代了Akka來實現Rpc通信框架,據官網稱:「Akka 的依賴性被移除,用戶可以使用任何版本的Akka來編程」。因爲Akka的不同版本間進行通信是有問題的。 內在RPC的基本架構組成 TransportContext:傳輸上下文,包含了用於創建傳輸服務端和傳輸客戶端工廠的上下文信息。 TransportConf: 傳輸上下文的配置信息。 RpcHandler:
相關文章
相關標籤/搜索