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.

results matching ""

    No results matching ""