RpcAddress¶
RpcAddress is a logical address of an RPC system, with hostname and port.
RpcAddress can be encoded as a Spark URL in the format of spark://host:port.
Creating Instance¶
RpcAddress takes the following to be created:
- Host
- Port
Creating RpcAddress based on Spark URL¶
fromSparkURL(
sparkUrl: String): RpcAddress
fromSparkURL extract a host and a port from the input Spark URL and creates an RpcAddress.
fromSparkURL is used when:
StandaloneAppClientis createdClientAppis requested to startWorkeris requested to startRpcEnvAndEndpoint