@InterfaceAudience.Private public final class RpcClientFactory extends java.lang.Object
RpcClient
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CUSTOM_RPC_CLIENT_IMPL_CONF_KEY |
Modifier and Type | Method and Description |
---|---|
static RpcClient |
createClient(Configuration conf,
java.lang.String clusterId)
Creates a new RpcClient by the class defined in the configuration or falls back to
RpcClientImpl
|
static RpcClient |
createClient(Configuration conf,
java.lang.String clusterId,
java.net.SocketAddress localAddr)
Creates a new RpcClient by the class defined in the configuration or falls back to
RpcClientImpl
|
public static final java.lang.String CUSTOM_RPC_CLIENT_IMPL_CONF_KEY
public static RpcClient createClient(Configuration conf, java.lang.String clusterId)
conf
- configurationclusterId
- the cluster idpublic static RpcClient createClient(Configuration conf, java.lang.String clusterId, java.net.SocketAddress localAddr)
conf
- configurationclusterId
- the cluster idlocalAddr
- client socket bind address.