org.apache.hadoop.hbase.client

Class TestClientNoCluster.ManyServersManyRegionsConnection

java.lang.Object

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 Object

Fake many regionservers and many regions on a connection implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	org.apache.hadoop.hbase.client.ConnectionImplementation.MasterServiceState
(package private) static class	org.apache.hadoop.hbase.client.ConnectionImplementation.ServerErrorTracker

Field Summary

Fields

Modifier and Type	Field and Description
protected String	clusterId
(package private) org.apache.hadoop.hbase.client.ClusterStatusListener	clusterStatusListener
private org.apache.hadoop.conf.Configuration	conf
(package private) org.apache.hadoop.hbase.client.ConnectionImplementation.MasterServiceState	masterServiceState
(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'.
static String	RETRIES_BY_SERVER_KEY
(package private) int	rpcTimeout
(package private) AtomicLong	sequenceids
(package private) Map<org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface>	serversByClient
protected org.apache.hadoop.hbase.security.User	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
void	abort(String arg0, Throwable arg1)
void	cacheLocation(org.apache.hadoop.hbase.TableName arg0, org.apache.hadoop.hbase.RegionLocations arg1)
void	clearCaches(org.apache.hadoop.hbase.ServerName arg0)
void	clearRegionCache(org.apache.hadoop.hbase.TableName arg0)
void	clearRegionCache(org.apache.hadoop.hbase.TableName arg0, byte[] arg1)
void	clearRegionLocationCache()
void	close()
void	deleteCachedRegionLocation(org.apache.hadoop.hbase.HRegionLocation arg0)
protected void	finalize()
org.apache.hadoop.hbase.client.Admin	getAdmin()
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface	getAdmin(org.apache.hadoop.hbase.ServerName arg0)
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface	getAdminForMaster()
org.apache.hadoop.hbase.client.AsyncProcess	getAsyncProcess()
org.apache.hadoop.hbase.client.backoff.ClientBackoffPolicy	getBackoffPolicy()
org.apache.hadoop.hbase.client.BufferedMutator	getBufferedMutator(org.apache.hadoop.hbase.client.BufferedMutatorParams arg0)
org.apache.hadoop.hbase.client.BufferedMutator	getBufferedMutator(org.apache.hadoop.hbase.TableName arg0)
(package private) org.apache.hadoop.hbase.RegionLocations	getCachedLocation(org.apache.hadoop.hbase.TableName arg0, byte[] arg1)
(package private) org.apache.hadoop.hbase.ChoreService	getChoreService()
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface	getClient(org.apache.hadoop.hbase.ServerName sn)
org.apache.hadoop.conf.Configuration	getConfiguration()
org.apache.hadoop.hbase.client.ConnectionConfiguration	getConnectionConfiguration()
org.apache.hadoop.hbase.client.MetricsConnection	getConnectionMetrics()
protected ExecutorService	getCurrentBatchPool()
protected ExecutorService	getCurrentMetaLookupPool()
org.apache.hadoop.hbase.client.Hbck	getHbck()
org.apache.hadoop.hbase.client.Hbck	getHbck(org.apache.hadoop.hbase.ServerName arg0)
org.apache.hadoop.hbase.client.MasterKeepAliveConnection	getMaster()
org.apache.hadoop.hbase.client.RpcRetryingCallerFactory	getNewRpcRetryingCallerFactory(org.apache.hadoop.conf.Configuration arg0)
org.apache.hadoop.hbase.client.NonceGenerator	getNonceGenerator()
(package private) int	getNumberOfCachedRegionLocations(org.apache.hadoop.hbase.TableName arg0)
org.apache.hadoop.hbase.HRegionLocation	getRegionLocation(org.apache.hadoop.hbase.TableName arg0, byte[] arg1, boolean arg2)
org.apache.hadoop.hbase.client.RegionLocator	getRegionLocator(org.apache.hadoop.hbase.TableName arg0)
(package private) org.apache.hadoop.hbase.ipc.RpcClient	getRpcClient()
org.apache.hadoop.hbase.ipc.RpcControllerFactory	getRpcControllerFactory()
org.apache.hadoop.hbase.client.RpcRetryingCallerFactory	getRpcRetryingCallerFactory()
org.apache.hadoop.hbase.client.ServerStatisticTracker	getStatisticsTracker()
org.apache.hadoop.hbase.client.Table	getTable(org.apache.hadoop.hbase.TableName arg0)
org.apache.hadoop.hbase.client.TableBuilder	getTableBuilder(org.apache.hadoop.hbase.TableName arg0, ExecutorService arg1)
org.apache.hadoop.hbase.client.TableState	getTableState(org.apache.hadoop.hbase.TableName arg0)
boolean	hasCellBlockSupport()
(package private) static org.apache.hadoop.hbase.client.NonceGenerator	injectNonceGeneratorForTesting(org.apache.hadoop.hbase.client.ClusterConnection arg0, org.apache.hadoop.hbase.client.NonceGenerator arg1)
boolean	isAborted()
boolean	isClosed()
boolean	isMasterRunning() Deprecated.
boolean	isTableAvailable(org.apache.hadoop.hbase.TableName arg0, byte[][] arg1)
boolean	isTableDisabled(org.apache.hadoop.hbase.TableName arg0)
boolean	isTableEnabled(org.apache.hadoop.hbase.TableName arg0)
org.apache.hadoop.hbase.HRegionLocation	locateRegion(byte[] arg0)
org.apache.hadoop.hbase.HRegionLocation	locateRegion(org.apache.hadoop.hbase.TableName arg0, byte[] arg1)
org.apache.hadoop.hbase.RegionLocations	locateRegion(org.apache.hadoop.hbase.TableName arg0, byte[] arg1, boolean arg2, boolean arg3)
org.apache.hadoop.hbase.RegionLocations	locateRegion(org.apache.hadoop.hbase.TableName arg0, byte[] arg1, boolean arg2, boolean arg3, int arg4)
List<org.apache.hadoop.hbase.HRegionLocation>	locateRegions(org.apache.hadoop.hbase.TableName arg0)
List<org.apache.hadoop.hbase.HRegionLocation>	locateRegions(org.apache.hadoop.hbase.TableName arg0, boolean arg1, boolean arg2)
(package private) void	releaseMaster(org.apache.hadoop.hbase.client.ConnectionImplementation.MasterServiceState arg0)
org.apache.hadoop.hbase.HRegionLocation	relocateRegion(org.apache.hadoop.hbase.TableName arg0, byte[] arg1)
org.apache.hadoop.hbase.RegionLocations	relocateRegion(org.apache.hadoop.hbase.TableName arg0, byte[] arg1, int arg2)
protected void	retrieveClusterId()
(package private) void	takeUserRegionLock()
String	toString()
(package private) void	updateCachedLocation(org.apache.hadoop.hbase.client.RegionInfo arg0, org.apache.hadoop.hbase.ServerName arg1, org.apache.hadoop.hbase.ServerName arg2, long arg3)
void	updateCachedLocations(org.apache.hadoop.hbase.TableName arg0, byte[] arg1, byte[] arg2, Object arg3, org.apache.hadoop.hbase.ServerName arg4)

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

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

RETRIES_BY_SERVER_KEY

public static final String RETRIES_BY_SERVER_KEY

See Also:

Constant Field Values

rpcTimeout

final int rpcTimeout

clusterStatusListener

org.apache.hadoop.hbase.client.ClusterStatusListener clusterStatusListener

user

protected org.apache.hadoop.hbase.security.User user

clusterId

protected String clusterId

masterServiceState

final org.apache.hadoop.hbase.client.ConnectionImplementation.MasterServiceState masterServiceState

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

Throws:

IOException

injectNonceGeneratorForTesting

static org.apache.hadoop.hbase.client.NonceGenerator injectNonceGeneratorForTesting(org.apache.hadoop.hbase.client.ClusterConnection arg0,
                                                                                    org.apache.hadoop.hbase.client.NonceGenerator arg1)

getTable

public org.apache.hadoop.hbase.client.Table getTable(org.apache.hadoop.hbase.TableName arg0)
                                              throws IOException

Specified by:

getTable in interface org.apache.hadoop.hbase.client.Connection

Throws:

IOException

getTableBuilder

public org.apache.hadoop.hbase.client.TableBuilder getTableBuilder(org.apache.hadoop.hbase.TableName arg0,
                                                                   ExecutorService arg1)

Specified by:

getTableBuilder in interface org.apache.hadoop.hbase.client.Connection

getBufferedMutator

public org.apache.hadoop.hbase.client.BufferedMutator getBufferedMutator(org.apache.hadoop.hbase.client.BufferedMutatorParams arg0)

Specified by:

getBufferedMutator in interface org.apache.hadoop.hbase.client.Connection

getBufferedMutator

public org.apache.hadoop.hbase.client.BufferedMutator getBufferedMutator(org.apache.hadoop.hbase.TableName arg0)

Specified by:

getBufferedMutator in interface org.apache.hadoop.hbase.client.Connection

getRegionLocator

public org.apache.hadoop.hbase.client.RegionLocator getRegionLocator(org.apache.hadoop.hbase.TableName arg0)
                                                              throws IOException

Specified by:

getRegionLocator in interface org.apache.hadoop.hbase.client.Connection

Throws:

IOException

getAdmin

public org.apache.hadoop.hbase.client.Admin getAdmin()
                                              throws IOException

Specified by:

getAdmin in interface org.apache.hadoop.hbase.client.Connection

Throws:

IOException

getHbck

public org.apache.hadoop.hbase.client.Hbck getHbck()
                                            throws IOException

Specified by:

getHbck in interface org.apache.hadoop.hbase.client.Connection

Throws:

IOException

getHbck

public org.apache.hadoop.hbase.client.Hbck getHbck(org.apache.hadoop.hbase.ServerName arg0)
                                            throws IOException

Specified by:

getHbck in interface org.apache.hadoop.hbase.client.Connection

Throws:

IOException

getConnectionMetrics

public org.apache.hadoop.hbase.client.MetricsConnection getConnectionMetrics()

Specified by:

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

getCurrentMetaLookupPool

protected ExecutorService getCurrentMetaLookupPool()

getCurrentBatchPool

protected ExecutorService getCurrentBatchPool()

getRpcClient

org.apache.hadoop.hbase.ipc.RpcClient getRpcClient()

toString

public String toString()

Overrides:

toString in class Object

retrieveClusterId

protected void retrieveClusterId()

getChoreService

org.apache.hadoop.hbase.ChoreService getChoreService()

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

Specified by:

getConfiguration in interface org.apache.hadoop.hbase.client.Connection

isMasterRunning

@Deprecated
public boolean isMasterRunning()
                                    throws org.apache.hadoop.hbase.MasterNotRunningException,
                                           org.apache.hadoop.hbase.ZooKeeperConnectionException

Deprecated.

Specified by:

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

Throws:

org.apache.hadoop.hbase.MasterNotRunningException

org.apache.hadoop.hbase.ZooKeeperConnectionException

getRegionLocation

public org.apache.hadoop.hbase.HRegionLocation getRegionLocation(org.apache.hadoop.hbase.TableName arg0,
                                                                 byte[] arg1,
                                                                 boolean arg2)
                                                          throws IOException

Specified by:

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

Throws:

IOException

isTableEnabled

public boolean isTableEnabled(org.apache.hadoop.hbase.TableName arg0)
                       throws IOException

Specified by:

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

Throws:

IOException

isTableDisabled

public boolean isTableDisabled(org.apache.hadoop.hbase.TableName arg0)
                        throws IOException

Specified by:

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

Throws:

IOException

isTableAvailable

public boolean isTableAvailable(org.apache.hadoop.hbase.TableName arg0,
                                @Nullable
                                byte[][] arg1)
                         throws IOException

Specified by:

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

Throws:

IOException

locateRegion

public org.apache.hadoop.hbase.HRegionLocation locateRegion(byte[] arg0)
                                                     throws IOException

Specified by:

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

Throws:

IOException

locateRegions

public List<org.apache.hadoop.hbase.HRegionLocation> locateRegions(org.apache.hadoop.hbase.TableName arg0)
                                                            throws IOException

Specified by:

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

Throws:

IOException

locateRegions

public List<org.apache.hadoop.hbase.HRegionLocation> locateRegions(org.apache.hadoop.hbase.TableName arg0,
                                                                   boolean arg1,
                                                                   boolean arg2)
                                                            throws IOException

Specified by:

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

Throws:

IOException

locateRegion

public org.apache.hadoop.hbase.HRegionLocation locateRegion(org.apache.hadoop.hbase.TableName arg0,
                                                            byte[] arg1)
                                                     throws IOException

Specified by:

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

Throws:

IOException

relocateRegion

public org.apache.hadoop.hbase.HRegionLocation relocateRegion(org.apache.hadoop.hbase.TableName arg0,
                                                              byte[] arg1)
                                                       throws IOException

Specified by:

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

Throws:

IOException

relocateRegion

public org.apache.hadoop.hbase.RegionLocations relocateRegion(org.apache.hadoop.hbase.TableName arg0,
                                                              byte[] arg1,
                                                              int arg2)
                                                       throws IOException

Specified by:

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

Throws:

IOException

locateRegion

public org.apache.hadoop.hbase.RegionLocations locateRegion(org.apache.hadoop.hbase.TableName arg0,
                                                            byte[] arg1,
                                                            boolean arg2,
                                                            boolean arg3)
                                                     throws IOException

Specified by:

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

Throws:

IOException

locateRegion

public org.apache.hadoop.hbase.RegionLocations locateRegion(org.apache.hadoop.hbase.TableName arg0,
                                                            byte[] arg1,
                                                            boolean arg2,
                                                            boolean arg3,
                                                            int arg4)
                                                     throws IOException

Specified by:

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

Throws:

IOException

takeUserRegionLock

void takeUserRegionLock()
                 throws IOException

Throws:

IOException

cacheLocation

public void cacheLocation(org.apache.hadoop.hbase.TableName arg0,
                          org.apache.hadoop.hbase.RegionLocations arg1)

Specified by:

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

getCachedLocation

org.apache.hadoop.hbase.RegionLocations getCachedLocation(org.apache.hadoop.hbase.TableName arg0,
                                                          byte[] arg1)

clearRegionCache

public void clearRegionCache(org.apache.hadoop.hbase.TableName arg0,
                             byte[] arg1)

clearCaches

public void clearCaches(org.apache.hadoop.hbase.ServerName arg0)

Specified by:

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

clearRegionLocationCache

public void clearRegionLocationCache()

Specified by:

clearRegionLocationCache in interface org.apache.hadoop.hbase.client.Connection

clearRegionCache

public void clearRegionCache(org.apache.hadoop.hbase.TableName arg0)

Specified by:

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

getAdminForMaster

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface getAdminForMaster()
                                                                                                               throws IOException

Specified by:

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

Throws:

IOException

getAdmin

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface getAdmin(org.apache.hadoop.hbase.ServerName arg0)
                                                                                                      throws IOException

Specified by:

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

Throws:

IOException

getMaster

public org.apache.hadoop.hbase.client.MasterKeepAliveConnection getMaster()
                                                                   throws IOException

Specified by:

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

Throws:

IOException

releaseMaster

void releaseMaster(org.apache.hadoop.hbase.client.ConnectionImplementation.MasterServiceState arg0)

updateCachedLocation

void updateCachedLocation(org.apache.hadoop.hbase.client.RegionInfo arg0,
                          org.apache.hadoop.hbase.ServerName arg1,
                          org.apache.hadoop.hbase.ServerName arg2,
                          long arg3)

deleteCachedRegionLocation

public void deleteCachedRegionLocation(org.apache.hadoop.hbase.HRegionLocation arg0)

Specified by:

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

updateCachedLocations

public void updateCachedLocations(org.apache.hadoop.hbase.TableName arg0,
                                  byte[] arg1,
                                  byte[] arg2,
                                  Object arg3,
                                  org.apache.hadoop.hbase.ServerName arg4)

Specified by:

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

getAsyncProcess

public org.apache.hadoop.hbase.client.AsyncProcess getAsyncProcess()

Specified by:

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

getStatisticsTracker

public org.apache.hadoop.hbase.client.ServerStatisticTracker getStatisticsTracker()

Specified by:

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

getBackoffPolicy

public org.apache.hadoop.hbase.client.backoff.ClientBackoffPolicy getBackoffPolicy()

Specified by:

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

getNumberOfCachedRegionLocations

int getNumberOfCachedRegionLocations(org.apache.hadoop.hbase.TableName arg0)

abort

public void abort(String arg0,
                  Throwable arg1)

Specified by:

abort in interface org.apache.hadoop.hbase.Abortable

isClosed

public boolean isClosed()

Specified by:

isClosed in interface org.apache.hadoop.hbase.client.Connection

isAborted

public boolean isAborted()

Specified by:

isAborted in interface org.apache.hadoop.hbase.Abortable

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.client.Connection

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

getNonceGenerator

public org.apache.hadoop.hbase.client.NonceGenerator getNonceGenerator()

Specified by:

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

getTableState

public org.apache.hadoop.hbase.client.TableState getTableState(org.apache.hadoop.hbase.TableName arg0)
                                                        throws IOException

Specified by:

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

Throws:

IOException

getNewRpcRetryingCallerFactory

public org.apache.hadoop.hbase.client.RpcRetryingCallerFactory getNewRpcRetryingCallerFactory(org.apache.hadoop.conf.Configuration arg0)

Specified by:

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

hasCellBlockSupport

public boolean hasCellBlockSupport()

Specified by:

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

getConnectionConfiguration

public org.apache.hadoop.hbase.client.ConnectionConfiguration getConnectionConfiguration()

Specified by:

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

getRpcRetryingCallerFactory

public org.apache.hadoop.hbase.client.RpcRetryingCallerFactory getRpcRetryingCallerFactory()

Specified by:

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

getRpcControllerFactory

public org.apache.hadoop.hbase.ipc.RpcControllerFactory getRpcControllerFactory()

Specified by:

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