RpcEnv是各个组件之间通信的执行环境,每个节点之间(Driver或者Worker或者executor)组件的Endpoint和对应的EndpointRef之间的信息通信和方法调用都是通过RpcEnv作协调,2.0版本以后将之前akka换成Netty NIO框架实现
![](https://img.haomeiwen.com/i6450093/cde4d57323c4b982.png)
调用伴生对象的create方法
![](https://img.haomeiwen.com/i6450093/00602ad825f8154c.png)
里面封装了NettyRpcEnvFactory方法
![](https://img.haomeiwen.com/i6450093/87e9a43941e6f944.png)
将来会支持KryoSerializer
RpcEnv是各个组件之间通信的执行环境,每个节点之间(Driver或者Worker或者executor)组件的Endpoint和对应的EndpointRef之间的信息通信和方法调用都是通过RpcEnv作协调,2.0版本以后将之前akka换成Netty NIO框架实现
调用伴生对象的create方法
里面封装了NettyRpcEnvFactory方法
将来会支持KryoSerializer
本文标题:Spark 组件之 RpcEnv
本文链接:https://www.haomeiwen.com/subject/vdgtwftx.html
网友评论