spark-RpcEnvFactory.adoc

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.

RpcEnvFactory Contract

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.