org.apache.hadoop.hbase.client

Class TestClientNoCluster.RpcTimeoutConnection

java.lang.Object

org.apache.hadoop.hbase.client.ConnectionImplementation

org.apache.hadoop.hbase.client.TestClientNoCluster.RpcTimeoutConnection

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.Abortable, org.apache.hadoop.hbase.client.ClusterConnection, org.apache.hadoop.hbase.client.Connection

Enclosing class:

TestClientNoCluster

static class TestClientNoCluster.RpcTimeoutConnection
extends org.apache.hadoop.hbase.client.ConnectionImplementation

Override to check we are setting rpc timeout right.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.client.ConnectionImplementation

org.apache.hadoop.hbase.client.ConnectionImplementation.MasterServiceState, org.apache.hadoop.hbase.client.ConnectionImplementation.ServerErrorTracker

Field Summary

Fields

Modifier and Type	Field and Description
(package private) org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface	stub

Fields inherited from class org.apache.hadoop.hbase.client.ConnectionImplementation

clusterId, clusterStatusListener, masterServiceState, RETRIES_BY_SERVER_KEY, rpcTimeout, user

Fields inherited from interface org.apache.hadoop.hbase.client.ClusterConnection

HBASE_CLIENT_CONNECTION_IMPL

Constructor Summary

Constructors

Constructor and Description
RpcTimeoutConnection(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, org.apache.hadoop.hbase.security.User user)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface	getClient(org.apache.hadoop.hbase.ServerName sn)

Methods inherited from class org.apache.hadoop.hbase.client.ConnectionImplementation

abort, cacheLocation, clearCaches, clearRegionCache, clearRegionCache, clearRegionLocationCache, close, deleteCachedRegionLocation, finalize, getAdmin, getAdmin, getAdminForMaster, getAsyncProcess, getBackoffPolicy, getBufferedMutator, getBufferedMutator, getCachedLocation, getChoreService, getClusterId, getConfiguration, getConnectionConfiguration, getConnectionMetrics, getConnectionRegistry, getCurrentBatchPool, getCurrentMetaLookupPool, getHbck, getHbck, getMaster, getNewRpcRetryingCallerFactory, getNonceGenerator, getNumberOfCachedRegionLocations, getRegionLocation, getRegionLocator, getRpcClient, getRpcControllerFactory, getRpcRetryingCallerFactory, getStatisticsTracker, getTable, getTableBuilder, getTableState, getUser, hasCellBlockSupport, injectNonceGeneratorForTesting, isAborted, isClosed, isMasterRunning, isTableAvailable, isTableDisabled, isTableEnabled, locateRegion, locateRegion, locateRegion, locateRegion, locateRegions, locateRegions, releaseMaster, relocateRegion, relocateRegion, retrieveClusterId, takeUserRegionLock, toString, updateCachedLocation, updateCachedLocations

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.client.ClusterConnection

clearRegionCache

Methods inherited from interface org.apache.hadoop.hbase.client.Connection

getTable

Methods inherited from interface org.apache.hadoop.hbase.Abortable

abort

Field Detail

stub

final org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface stub

Constructor Detail

RpcTimeoutConnection

RpcTimeoutConnection(org.apache.hadoop.conf.Configuration conf,
                     ExecutorService pool,
                     org.apache.hadoop.hbase.security.User user)
              throws IOException

Throws:

IOException

Method Detail

getClient

public org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface getClient(org.apache.hadoop.hbase.ServerName sn)
                                                                                                         throws IOException

Specified by:

getClient in interface org.apache.hadoop.hbase.client.ClusterConnection

Overrides:

getClient in class org.apache.hadoop.hbase.client.ConnectionImplementation

Throws:

IOException