@InterfaceAudience.Private public class BlockingRpcClient extends AbstractRpcClient<org.apache.hadoop.hbase.ipc.BlockingRpcConnection>
See HBaseServer
AbstractRpcClient.BlockingRpcChannelImplementation, AbstractRpcClient.RpcChannelImplementation| Modifier and Type | Field and Description |
|---|---|
protected SocketFactory |
socketFactory |
cellBlockBuilder, clusterId, codec, compressor, conf, connections, connectTO, failedServers, failureSleep, fallbackAllowed, localAddr, LOG, maxRetries, metrics, minIdleTimeBeforeClose, readTO, running, tcpKeepAlive, tcpNoDelay, TOKEN_HANDLERS, userProvider, WHEEL_TIMER, writeTODEFAULT_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,
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 org.apache.hadoop.hbase.ipc.BlockingRpcConnection |
createConnection(ConnectionId remoteId)
Creates a connection.
|
cancelConnections, close, createBlockingRpcChannel, createRpcChannel, getDefaultCodec, hasCellBlockSupportprotected final SocketFactory socketFactory
public 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 org.apache.hadoop.hbase.ipc.BlockingRpcConnection createConnection(ConnectionId remoteId) throws IOException
createConnection in class AbstractRpcClient<org.apache.hadoop.hbase.ipc.BlockingRpcConnection>remoteId - - the ConnectionId to use for the connection creation.IOExceptionprotected void closeInternal()
closeInternal in class AbstractRpcClient<org.apache.hadoop.hbase.ipc.BlockingRpcConnection>Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.