Package 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
    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
    Description
    (package private) final AtomicInteger
    nbThreads
     

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

    clusterId, clusterStatusListener, MASTER_STATE_CACHE_TIMEOUT_SEC, 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
    Description
    protected
    MyConnectionImpl(org.apache.hadoop.conf.Configuration conf)
     

  • Method Summary

    Modifier and Type
    Method
    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, finalize, getAdmin, getAdmin, getAdminForMaster, getAllBootstrapNodes, getAsyncProcess, getBackoffPolicy, getBufferedMutator, getBufferedMutator, getCachedLocation, getChoreService, getClient, getClusterId, getConfiguration, getConnectionConfiguration, getConnectionMetrics, getConnectionRegistry, getCurrentBatchPool, getCurrentMetaLookupPool, getHbck, getHbck, getLiveRegionServers, getMaster, getMasterServiceState, 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, masterConnectionStateSupplier, 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.Abortable

    abort

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

    clearRegionCache

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

    getTable

  • Field Details

  • Constructor Details

  • Method Details

    • 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