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