Spark Netty 通信框架解析

  1、RpcEndpoint: RPC端点 Spark针对每个节点(Client、Master、Worker)都称之为一个RpcEndpoint,且都实现RpcEndpoint接口,内部根据不同端点的需求,设计不同的消息和不同的业务处理,如果需要发送(询问)则内部调用Dispatcher的对应方法 说明: RpcEndpoint 用来接收消息 RpcEndpointRef 用来发送消息 RpcE
相关文章
相关标签/搜索