org.apache.hadoop.hbase.client

Class TestAsyncProcess.MyConnectionImpl

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncProcess.MyConnectionImpl

All Implemented Interfaces:

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

Direct Known Subclasses:

TestAsyncProcess.MyConnectionImpl2

Enclosing class:

TestAsyncProcess

static class TestAsyncProcess.MyConnectionImpl
extends Object

Returns our async process.

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
static class	TestAsyncProcess.MyConnectionImpl.TestRegistry

Field Summary

Fields

Modifier and Type	Field and Description
protected String	clusterId
(package private) org.apache.hadoop.hbase.client.ClusterStatusListener	clusterStatusListener
(package private) org.apache.hadoop.hbase.client.ConnectionImplementation.MasterServiceState	masterServiceState
(package private) AtomicInteger	nbThreads
static String	RETRIES_BY_SERVER_KEY
(package private) int	rpcTimeout
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

Modifier	Constructor and Description
protected	MyConnectionImpl(org.apache.hadoop.conf.Configuration conf)

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()
void	clearRegionCache(org.apache.hadoop.hbase.TableName arg0)
void	clearRegionCache(org.apache.hadoop.hbase.TableName arg0, byte[] arg1)
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)
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface	getClient(org.apache.hadoop.hbase.ServerName arg0)
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()
int	getCurrentNrHRS()
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 tableName, byte[] row, boolean useCache, boolean retry, int replicaId)
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()
private static org.apache.hadoop.conf.Configuration	setupConf(org.apache.hadoop.conf.Configuration conf)
(package private) void	setUseMetaReplicas(boolean arg0)
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.Connection

getTable

Field Detail

nbThreads

final AtomicInteger nbThreads

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

MyConnectionImpl

protected MyConnectionImpl(org.apache.hadoop.conf.Configuration conf)
                    throws IOException

Throws:

IOException

Method Detail

setupConf

private static org.apache.hadoop.conf.Configuration setupConf(org.apache.hadoop.conf.Configuration conf)

locateRegion

public org.apache.hadoop.hbase.RegionLocations locateRegion(org.apache.hadoop.hbase.TableName tableName,
                                                            byte[] row,
                                                            boolean useCache,
                                                            boolean retry,
                                                            int replicaId)
                                                     throws IOException

Specified by:

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

Throws:

IOException

hasCellBlockSupport

public boolean hasCellBlockSupport()

Specified by:

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

setUseMetaReplicas

void setUseMetaReplicas(boolean arg0)

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.ClusterConnection

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.ClusterConnection

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

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

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

clearRegionCache

public void clearRegionCache()

Specified by:

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

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

getClient

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

Specified by:

getClient 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

getCurrentNrHRS

public int getCurrentNrHRS()
                    throws IOException

Specified by:

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

Throws:

IOException

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

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