RpcEnv是各个组件之间通信的执行环境,每个节点之间(Driver或者Worker或者executor)组件的Endpoint和对应的EndpointRef之间的信息通信和方法调用都是通过RpcEnv作协调,2.0版本以后将之前akka换成Netty NIO框架实现

调用伴生对象的create方法

里面封装了NettyRpcEnvFactory方法

将来会支持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
网友评论