@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.