Spark的内置RPC通信框架

spark2.x.x后使用Netty替代了Akka来实现Rpc通信框架,据官网称:“Akka 的依赖性被移除,用户可以使用任何版本的Akka来编程”。因为Akka的不同版本间进行通信是有问题的。 内在RPC的基本架构组成 TransportContext:传输上下文,包含了用于创建传输服务端和传输客户端工厂的上下文信息。 TransportConf: 传输上下文的配置信息。 RpcHandler:
相关文章
相关标签/搜索