@InterfaceAudience.Private public class BlockingRpcClient extends AbstractRpcClient<BlockingRpcConnection>
See HBaseServer
AbstractRpcClient.BlockingRpcChannelImplementation, AbstractRpcClient.RpcChannelImplementation
Modifier and Type | Field and Description |
---|---|
protected SocketFactory |
socketFactory |
cellBlockBuilder, clusterId, codec, compressor, conf, connectTO, failedServers, failureSleep, fallbackAllowed, localAddr, LOG, maxRetries, metrics, minIdleTimeBeforeClose, readTO, tcpKeepAlive, tcpNoDelay, userProvider, WHEEL_TIMER, writeTO
DEFAULT_CODEC_CLASS, DEFAULT_SOCKET_TIMEOUT_CONNECT, DEFAULT_SOCKET_TIMEOUT_READ, DEFAULT_SOCKET_TIMEOUT_WRITE, FAILED_SERVER_EXPIRY_DEFAULT, FAILED_SERVER_EXPIRY_KEY, IDLE_TIME, IPC_CLIENT_FALLBACK_TO_SIMPLE_AUTH_ALLOWED_DEFAULT, IPC_CLIENT_FALLBACK_TO_SIMPLE_AUTH_ALLOWED_KEY, PING_CALL_ID, SOCKET_TIMEOUT_CONNECT, SOCKET_TIMEOUT_READ, SOCKET_TIMEOUT_WRITE, SPECIFIC_WRITE_THREAD
Constructor and Description |
---|
BlockingRpcClient(org.apache.hadoop.conf.Configuration conf)
Used in test only.
|
BlockingRpcClient(org.apache.hadoop.conf.Configuration conf,
String clusterId,
SocketAddress localAddr,
MetricsConnection metrics)
Construct an IPC client for the cluster
clusterId with the default SocketFactory This
method is called with reflection by the RpcClientFactory to create an instance |
Modifier and Type | Method and Description |
---|---|
protected void |
closeInternal() |
protected BlockingRpcConnection |
createConnection(ConnectionId remoteId)
Creates a connection.
|
cancelConnections, close, configureHBaseRpcController, createBlockingRpcChannel, createRpcChannel, getCodec, getDefaultCodec, hasCellBlockSupport, isTcpNoDelay
protected final SocketFactory socketFactory
BlockingRpcClient(org.apache.hadoop.conf.Configuration conf)
clusterId
with the default
SocketFactorypublic BlockingRpcClient(org.apache.hadoop.conf.Configuration conf, String clusterId, SocketAddress localAddr, MetricsConnection metrics)
clusterId
with the default SocketFactory This
method is called with reflection by the RpcClientFactory to create an instanceconf
- configurationclusterId
- the cluster idlocalAddr
- client socket bind address.metrics
- the connection metricsprotected BlockingRpcConnection createConnection(ConnectionId remoteId) throws IOException
createConnection
in class AbstractRpcClient<BlockingRpcConnection>
remoteId
- - the ConnectionId to use for the connection creation.IOException
protected void closeInternal()
closeInternal
in class AbstractRpcClient<BlockingRpcConnection>
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.