org.apache.hadoop.hbase.ipc

Class NettyRpcClient

java.lang.Object

org.apache.hadoop.hbase.ipc.AbstractRpcClient<NettyRpcConnection>

org.apache.hadoop.hbase.ipc.NettyRpcClient

All Implemented Interfaces:

Closeable, AutoCloseable, RpcClient

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class NettyRpcClient
extends AbstractRpcClient<NettyRpcConnection>

Netty client for the requests and responses.

Since:

2.0.0

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.ipc.AbstractRpcClient

AbstractRpcClient.BlockingRpcChannelImplementation, AbstractRpcClient.RpcChannelImplementation

Field Summary

Fields

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

Fields inherited from class org.apache.hadoop.hbase.ipc.AbstractRpcClient

cellBlockBuilder, clusterId, codec, compressor, conf, connectTO, failedServers, failureSleep, fallbackAllowed, localAddr, LOG, maxRetries, metrics, minIdleTimeBeforeClose, readTO, tcpKeepAlive, tcpNoDelay, userProvider, WHEEL_TIMER, writeTO

Fields inherited from interface org.apache.hadoop.hbase.ipc.RpcClient

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 Summary

Constructors

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)

Method Summary

Modifier and Type	Method and Description
protected void	closeInternal()
protected NettyRpcConnection	createConnection(ConnectionId remoteId) Not connected.

Methods inherited from class org.apache.hadoop.hbase.ipc.AbstractRpcClient

callMethod, cancelConnections, close, configureHBaseRpcController, createAddr, createBlockingRpcChannel, createRpcChannel, getCodec, getDefaultCodec, hasCellBlockSupport, isTcpNoDelay

Methods inherited from class java.lang.Object

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

Field Detail

group

final org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup group

channelClass

final Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass

shutdownGroupWhenClose

private final boolean shutdownGroupWhenClose

Constructor Detail

NettyRpcClient

public NettyRpcClient(org.apache.hadoop.conf.Configuration configuration,
                      String clusterId,
                      SocketAddress localAddress,
                      MetricsConnection metrics)

NettyRpcClient

NettyRpcClient(org.apache.hadoop.conf.Configuration configuration)

Used in test only.

Method Detail

createConnection

protected NettyRpcConnection createConnection(ConnectionId remoteId)
                                       throws IOException

Description copied from class: AbstractRpcClient

Not connected.

Specified by:

createConnection in class AbstractRpcClient<NettyRpcConnection>

Throws:

IOException

closeInternal

protected void closeInternal()

Specified by:

closeInternal in class AbstractRpcClient<NettyRpcConnection>