org.apache.hadoop.hbase.client

Class TestAsyncProcess.MyConnectionImpl

java.lang.Object

org.apache.hadoop.hbase.client.ConnectionImplementation

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

Returns our async process.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestAsyncProcess.MyConnectionImpl.TestRegistry

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) AtomicInteger	nbThreads

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

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

Method Summary

Modifier and Type	Method and Description
boolean	hasCellBlockSupport()
org.apache.hadoop.hbase.RegionLocations	locateRegion(org.apache.hadoop.hbase.TableName tableName, byte[] row, boolean useCache, boolean retry, int replicaId)
private static org.apache.hadoop.conf.Configuration	setupConf(org.apache.hadoop.conf.Configuration conf)

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, getClient, getClusterId, getConfiguration, getConnectionConfiguration, getConnectionMetrics, getConnectionRegistry, getCurrentBatchPool, getCurrentMetaLookupPool, getHbck, getHbck, getMaster, getNewRpcRetryingCallerFactory, getNonceGenerator, getNumberOfCachedRegionLocations, getRegionLocation, getRegionLocator, getRpcClient, getRpcControllerFactory, getRpcRetryingCallerFactory, getStatisticsTracker, getTable, getTableBuilder, getTableState, getUser, injectNonceGeneratorForTesting, isAborted, isClosed, isMasterRunning, isTableAvailable, isTableDisabled, isTableEnabled, 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

nbThreads

final AtomicInteger nbThreads

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

Overrides:

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

Throws:

IOException

hasCellBlockSupport

public boolean hasCellBlockSupport()

Specified by:

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

Overrides:

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