Spark 组件之 RpcEnv

2018-08-27  本文已影响15人  scottzcw

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

调用伴生对象的create方法

里面封装了NettyRpcEnvFactory方法

将来会支持KryoSerializer

上一篇 下一篇

猜你喜欢

热点阅读