trait RpcEnvFactory {
def create(config: RpcEnvConfig): RpcEnv
}
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
Note
|
RpcEnvFactory is a private[spark] contract.
|
Method | Description |
---|---|
Used when |