@InterfaceAudience.Private public final class RpcClientFactory extends Object
RpcClient
Modifier and Type | Field and Description |
---|---|
static String |
CUSTOM_RPC_CLIENT_IMPL_CONF_KEY |
Modifier and Type | Method and Description |
---|---|
static RpcClient |
createClient(org.apache.hadoop.conf.Configuration conf,
String clusterId)
Creates a new RpcClient by the class defined in the configuration or falls back to
RpcClientImpl
|
static RpcClient |
createClient(org.apache.hadoop.conf.Configuration conf,
String clusterId,
SocketAddress localAddr)
Creates a new RpcClient by the class defined in the configuration or falls back to
RpcClientImpl
|
public static final String CUSTOM_RPC_CLIENT_IMPL_CONF_KEY
public static RpcClient createClient(org.apache.hadoop.conf.Configuration conf, String clusterId)
conf
- configurationclusterId
- the cluster idpublic static RpcClient createClient(org.apache.hadoop.conf.Configuration conf, String clusterId, SocketAddress localAddr)
conf
- configurationclusterId
- the cluster idlocalAddr
- client socket bind address.Copyright © 2007-2016 The Apache Software Foundation. All Rights Reserved.