@InterfaceAudience.LimitedPrivate(value="Configuration") public class NettyRpcClient extends AbstractRpcClient<NettyRpcConnection>
AbstractRpcClient.BlockingRpcChannelImplementation, AbstractRpcClient.RpcChannelImplementation
Modifier and Type | Field and Description |
---|---|
(package private) Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> |
channelClass |
(package private) org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup |
group |
private boolean |
shutdownGroupWhenClose |
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 |
---|
NettyRpcClient(org.apache.hadoop.conf.Configuration configuration)
Used in test only.
|
NettyRpcClient(org.apache.hadoop.conf.Configuration configuration,
String clusterId,
SocketAddress localAddress,
MetricsConnection metrics) |
Modifier and Type | Method and Description |
---|---|
protected void |
closeInternal() |
protected NettyRpcConnection |
createConnection(ConnectionId remoteId)
Not connected.
|
cancelConnections, close, configureHBaseRpcController, createBlockingRpcChannel, createRpcChannel, getCodec, getDefaultCodec, hasCellBlockSupport, isTcpNoDelay
final org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup group
final Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass
private final boolean shutdownGroupWhenClose
public NettyRpcClient(org.apache.hadoop.conf.Configuration configuration, String clusterId, SocketAddress localAddress, MetricsConnection metrics)
NettyRpcClient(org.apache.hadoop.conf.Configuration configuration)
protected NettyRpcConnection createConnection(ConnectionId remoteId) throws IOException
AbstractRpcClient
createConnection
in class AbstractRpcClient<NettyRpcConnection>
IOException
protected void closeInternal()
closeInternal
in class AbstractRpcClient<NettyRpcConnection>
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.