Package org.apache.hadoop.hbase.ipc

Class RpcClientFactory

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcClientFactory

@Private
public final class RpcClientFactory
extends Object

Factory to create a RpcClient

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CUSTOM_RPC_CLIENT_IMPL_CONF_KEY
private static final org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<String,String>	DEPRECATED_NAME_MAPPING

Constructor Summary

Constructors

Modifier	Constructor	Description
private	RpcClientFactory()	Private Constructor

Method Summary

Modifier and Type	Method	Description
static RpcClient	createClient(org.apache.hadoop.conf.Configuration conf, String clusterId)	Helper method for tests only.
static RpcClient	createClient(org.apache.hadoop.conf.Configuration conf, String clusterId, SocketAddress localAddr, MetricsConnection metrics, Map<String,byte[]> connectionAttributes)	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, MetricsConnection metrics)	Creates a new RpcClient by the class defined in the configuration or falls back to RpcClientImpl
private static String	getRpcClientClass(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

CUSTOM_RPC_CLIENT_IMPL_CONF_KEY

public static final String CUSTOM_RPC_CLIENT_IMPL_CONF_KEY

See Also:

• Constant Field Values

DEPRECATED_NAME_MAPPING

private static final org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<String,String> DEPRECATED_NAME_MAPPING

Constructor Details

RpcClientFactory

private RpcClientFactory()

Private Constructor

Method Details

createClient

public static RpcClient createClient(org.apache.hadoop.conf.Configuration conf,
 String clusterId)

Helper method for tests only. Creates an RpcClient without metrics.

createClient

public static RpcClient createClient(org.apache.hadoop.conf.Configuration conf,
 String clusterId,
 MetricsConnection metrics)

Creates a new RpcClient by the class defined in the configuration or falls back to RpcClientImpl

Parameters:

conf - configuration

clusterId - the cluster id

metrics - the connection metrics

Returns:

newly created RpcClient

getRpcClientClass

private static String getRpcClientClass(org.apache.hadoop.conf.Configuration conf)

createClient

public static RpcClient createClient(org.apache.hadoop.conf.Configuration conf,
 String clusterId,
 SocketAddress localAddr,
 MetricsConnection metrics,
 Map<String,byte[]> connectionAttributes)

Creates a new RpcClient by the class defined in the configuration or falls back to RpcClientImpl

Parameters:

conf - configuration

clusterId - the cluster id

localAddr - client socket bind address.

metrics - the connection metrics

Returns:

newly created RpcClient