RpcEnvFactory-spark技术分享

RpcEnvFactory

RpcEnvFactory is the contract to create a RPC Environment.

Note	As of this commit in Spark 2, the one and only `RpcEnvFactory` is Netty-based `NettyRpcEnvFactory`.



trait RpcEnvFactory {
  def create(config: RpcEnvConfig): RpcEnv
}

trait RpcEnvFactory {

def create(config: RpcEnvConfig): RpcEnv

}

Note	`RpcEnvFactory` is a `private[spark]` contract.

Table 1. RpcEnvFactory Contract
Method	Description
`create`	Used when `RpcEnv` creates a RPC Environment.