org.apache.hadoop.hbase.client

Class TestMasterRegistryHedgedReads.RpcClientImpl

java.lang.Object

org.apache.hadoop.hbase.client.TestMasterRegistryHedgedReads.RpcClientImpl

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.ipc.RpcClient

Enclosing class:

TestMasterRegistryHedgedReads

public static final class TestMasterRegistryHedgedReads.RpcClientImpl
extends Object
implements org.apache.hadoop.hbase.ipc.RpcClient

Field Summary

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
RpcClientImpl(org.apache.hadoop.conf.Configuration configuration, String clusterId, SocketAddress localAddress, org.apache.hadoop.hbase.client.MetricsConnection metrics)

Method Summary

Modifier and Type	Method and Description
void	cancelConnections(org.apache.hadoop.hbase.ServerName sn)
void	close()
org.apache.hbase.thirdparty.com.google.protobuf.BlockingRpcChannel	createBlockingRpcChannel(org.apache.hadoop.hbase.ServerName sn, org.apache.hadoop.hbase.security.User user, int rpcTimeout)
org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel	createRpcChannel(org.apache.hadoop.hbase.ServerName sn, org.apache.hadoop.hbase.security.User user, int rpcTimeout)
boolean	hasCellBlockSupport()

Methods inherited from class java.lang.Object

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

Constructor Detail

RpcClientImpl

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

Method Detail

createBlockingRpcChannel

public org.apache.hbase.thirdparty.com.google.protobuf.BlockingRpcChannel createBlockingRpcChannel(org.apache.hadoop.hbase.ServerName sn,
                                                                                                   org.apache.hadoop.hbase.security.User user,
                                                                                                   int rpcTimeout)
                                                                                            throws IOException

Specified by:

createBlockingRpcChannel in interface org.apache.hadoop.hbase.ipc.RpcClient

Throws:

IOException

createRpcChannel

public org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel createRpcChannel(org.apache.hadoop.hbase.ServerName sn,
                                                                                   org.apache.hadoop.hbase.security.User user,
                                                                                   int rpcTimeout)
                                                                            throws IOException

Specified by:

createRpcChannel in interface org.apache.hadoop.hbase.ipc.RpcClient

Throws:

IOException

cancelConnections

public void cancelConnections(org.apache.hadoop.hbase.ServerName sn)

Specified by:

cancelConnections in interface org.apache.hadoop.hbase.ipc.RpcClient

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.hadoop.hbase.ipc.RpcClient

hasCellBlockSupport

public boolean hasCellBlockSupport()

Specified by:

hasCellBlockSupport in interface org.apache.hadoop.hbase.ipc.RpcClient