org.apache.hadoop.hbase.client

Class TestClientNoCluster.ManyServersManyRegionsConnection

java.lang.Object

org.apache.hadoop.hbase.client.ConnectionImplementation

org.apache.hadoop.hbase.client.TestClientNoCluster.ManyServersManyRegionsConnection

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.ManyServersManyRegionsConnection
extends org.apache.hadoop.hbase.client.ConnectionImplementation

Fake many regionservers and many regions on a connection implementation.

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
private org.apache.hadoop.conf.Configuration	conf
(package private) SortedMap<byte[],org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.HRegionInfo,org.apache.hadoop.hbase.ServerName>>	meta Map of faked-up rows of a 'meta table'.
(package private) AtomicLong	sequenceids
(package private) Map<org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface>	serversByClient

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
ManyServersManyRegionsConnection(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

serversByClient

final Map<org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface> serversByClient

meta

final SortedMap<byte[],org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.HRegionInfo,org.apache.hadoop.hbase.ServerName>> meta

Map of faked-up rows of a 'meta table'.

sequenceids

final AtomicLong sequenceids

conf

private final org.apache.hadoop.conf.Configuration conf

Constructor Detail

ManyServersManyRegionsConnection

ManyServersManyRegionsConnection(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