org.apache.hadoop.hbase.client

Class AsyncConnectionImpl

java.lang.Object

org.apache.hadoop.hbase.client.AsyncConnectionImpl

All Implemented Interfaces:

Closeable, AutoCloseable, AsyncConnection

@InterfaceAudience.Private
class AsyncConnectionImpl
extends Object
implements AsyncConnection

The implementation of AsyncConnection.

Field Summary

Fields

Modifier and Type	Field and Description
private ConcurrentMap<String,org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.Interface>	adminSubs
(package private) AsyncRpcRetryingCallerFactory	callerFactory
private org.apache.hadoop.conf.Configuration	conf
(package private) AsyncConnectionConfiguration	connConf
private boolean	hostnameCanChange
private AsyncRegionLocator	locator
private static org.slf4j.Logger	LOG
private AtomicReference<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface>	masterStub
private AtomicReference<CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface>>	masterStubMakeFuture
private NonceGenerator	nonceGenerator
(package private) AsyncRegistry	registry
private static String	RESOLVE_HOSTNAME_ON_FAIL_KEY
(package private) static org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer	RETRY_TIMER
private RpcClient	rpcClient
(package private) RpcControllerFactory	rpcControllerFactory
private int	rpcTimeout
private ConcurrentMap<String,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface>	rsStubs
private User	user

Constructor Summary

Constructors

Constructor and Description
AsyncConnectionImpl(org.apache.hadoop.conf.Configuration conf, AsyncRegistry registry, String clusterId, User user)

Method Summary

Modifier and Type	Method and Description
void	close()
private org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.Interface	createAdminServerStub(ServerName serverName)
private org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface	createMasterStub(ServerName serverName)
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface	createRegionServerStub(ServerName serverName)
AsyncAdminBuilder	getAdminBuilder() Returns an AsyncAdminBuilder for creating AsyncAdmin.
AsyncAdminBuilder	getAdminBuilder(ExecutorService pool) Returns an AsyncAdminBuilder for creating AsyncAdmin.
(package private) org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.Interface	getAdminStub(ServerName serverName)
AsyncBufferedMutatorBuilder	getBufferedMutatorBuilder(TableName tableName) Returns an AsyncBufferedMutatorBuilder for creating AsyncBufferedMutator.
AsyncBufferedMutatorBuilder	getBufferedMutatorBuilder(TableName tableName, ExecutorService pool) Returns an AsyncBufferedMutatorBuilder for creating AsyncBufferedMutator.
org.apache.hadoop.conf.Configuration	getConfiguration() Returns the Configuration object used by this instance.
CompletableFuture<Hbck>	getHbck() Retrieve an Hbck implementation to fix an HBase cluster.
Hbck	getHbck(ServerName masterServer) Retrieve an Hbck implementation to fix an HBase cluster.
(package private) AsyncRegionLocator	getLocator()
(package private) CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface>	getMasterStub()
NonceGenerator	getNonceGenerator()
AsyncTableRegionLocator	getRegionLocator(TableName tableName) Retrieve a AsyncRegionLocator implementation to inspect region information on a table.
(package private) org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface	getRegionServerStub(ServerName serverName)
private HBaseRpcController	getRpcController()
AsyncTableBuilder<AdvancedScanResultConsumer>	getTableBuilder(TableName tableName) Returns an AsyncTableBuilder for creating AsyncTable.
AsyncTableBuilder<ScanResultConsumer>	getTableBuilder(TableName tableName, ExecutorService pool) Returns an AsyncTableBuilder for creating AsyncTable.
private void	makeMasterStub(CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface> future)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

getAdmin, getAdmin, getBufferedMutator, getBufferedMutator, getTable, getTable

Field Detail

LOG

private static final org.slf4j.Logger LOG

RETRY_TIMER

static final org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer RETRY_TIMER

RESOLVE_HOSTNAME_ON_FAIL_KEY

private static final String RESOLVE_HOSTNAME_ON_FAIL_KEY

See Also:

Constant Field Values

conf

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

connConf

final AsyncConnectionConfiguration connConf

user

private final User user

registry

final AsyncRegistry registry

rpcTimeout

private final int rpcTimeout

rpcClient

private final RpcClient rpcClient

rpcControllerFactory

final RpcControllerFactory rpcControllerFactory

hostnameCanChange

private final boolean hostnameCanChange

locator

private final AsyncRegionLocator locator

callerFactory

final AsyncRpcRetryingCallerFactory callerFactory

nonceGenerator

private final NonceGenerator nonceGenerator

rsStubs

private final ConcurrentMap<String,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface> rsStubs

adminSubs

private final ConcurrentMap<String,org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.Interface> adminSubs

masterStub

private final AtomicReference<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface> masterStub

masterStubMakeFuture

private final AtomicReference<CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface>> masterStubMakeFuture

Constructor Detail

AsyncConnectionImpl

public AsyncConnectionImpl(org.apache.hadoop.conf.Configuration conf,
                           AsyncRegistry registry,
                           String clusterId,
                           User user)

Method Detail

getConfiguration

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

Description copied from interface: AsyncConnection

Returns the Configuration object used by this instance.

The reference returned is not a copy, so any change made to it will affect this instance.

Specified by:

getConfiguration in interface AsyncConnection

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

getRegionLocator

public AsyncTableRegionLocator getRegionLocator(TableName tableName)

Description copied from interface: AsyncConnection

Retrieve a AsyncRegionLocator implementation to inspect region information on a table. The returned AsyncRegionLocator is not thread-safe, so a new instance should be created for each using thread. This is a lightweight operation. Pooling or caching of the returned AsyncRegionLocator is neither required nor desired.

Specified by:

getRegionLocator in interface AsyncConnection

Parameters:

tableName - Name of the table who's region is to be examined

Returns:

An AsyncRegionLocator instance

getLocator

AsyncRegionLocator getLocator()

getNonceGenerator

public NonceGenerator getNonceGenerator()

createRegionServerStub

private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface createRegionServerStub(ServerName serverName)
                                                                                                               throws IOException

Throws:

IOException

getRegionServerStub

org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface getRegionServerStub(ServerName serverName)
                                                                                                    throws IOException

Throws:

IOException

createMasterStub

private org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface createMasterStub(ServerName serverName)
                                                                                                         throws IOException

Throws:

IOException

createAdminServerStub

private org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.Interface createAdminServerStub(ServerName serverName)
                                                                                                            throws IOException

Throws:

IOException

getAdminStub

org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.Interface getAdminStub(ServerName serverName)
                                                                                           throws IOException

Throws:

IOException

makeMasterStub

private void makeMasterStub(CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface> future)

getMasterStub

CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface> getMasterStub()

getRpcController

private HBaseRpcController getRpcController()

getTableBuilder

public AsyncTableBuilder<AdvancedScanResultConsumer> getTableBuilder(TableName tableName)

Description copied from interface: AsyncConnection

Returns an AsyncTableBuilder for creating AsyncTable.

This method no longer checks table existence. An exception will be thrown if the table does not exist only when the first operation is attempted.

Specified by:

getTableBuilder in interface AsyncConnection

Parameters:

tableName - the name of the table

getTableBuilder

public AsyncTableBuilder<ScanResultConsumer> getTableBuilder(TableName tableName,
                                                             ExecutorService pool)

Description copied from interface: AsyncConnection

Returns an AsyncTableBuilder for creating AsyncTable.

This method no longer checks table existence. An exception will be thrown if the table does not exist only when the first operation is attempted.

Specified by:

getTableBuilder in interface AsyncConnection

Parameters:

tableName - the name of the table

pool - the thread pool to use for executing callback

getAdminBuilder

public AsyncAdminBuilder getAdminBuilder()

Description copied from interface: AsyncConnection

Returns an AsyncAdminBuilder for creating AsyncAdmin.

The admin operation's returned CompletableFuture will be finished directly in the rpc framework's callback thread, so typically you should not do any time consuming work inside these methods.

Specified by:

getAdminBuilder in interface AsyncConnection

getAdminBuilder

public AsyncAdminBuilder getAdminBuilder(ExecutorService pool)

Description copied from interface: AsyncConnection

Returns an AsyncAdminBuilder for creating AsyncAdmin.

Specified by:

getAdminBuilder in interface AsyncConnection

Parameters:

pool - the thread pool to use for executing callback

getBufferedMutatorBuilder

public AsyncBufferedMutatorBuilder getBufferedMutatorBuilder(TableName tableName)

Description copied from interface: AsyncConnection

Returns an AsyncBufferedMutatorBuilder for creating AsyncBufferedMutator.

Specified by:

getBufferedMutatorBuilder in interface AsyncConnection

Parameters:

tableName - the name of the table

getBufferedMutatorBuilder

public AsyncBufferedMutatorBuilder getBufferedMutatorBuilder(TableName tableName,
                                                             ExecutorService pool)

Description copied from interface: AsyncConnection

Returns an AsyncBufferedMutatorBuilder for creating AsyncBufferedMutator.

Specified by:

getBufferedMutatorBuilder in interface AsyncConnection

Parameters:

tableName - the name of the table

pool - the thread pool to use for executing callback

getHbck

public CompletableFuture<Hbck> getHbck()

Description copied from interface: AsyncConnection

Retrieve an Hbck implementation to fix an HBase cluster. The returned Hbck is not guaranteed to be thread-safe. A new instance should be created by each thread. This is a lightweight operation. Pooling or caching of the returned Hbck instance is not recommended.

The caller is responsible for calling Closeable.close() on the returned Hbck instance.

This will be used mostly by hbck tool.

Specified by:

getHbck in interface AsyncConnection

Returns:

an Hbck instance for active master. Active master is fetched from the zookeeper.

getHbck

public Hbck getHbck(ServerName masterServer)
             throws IOException

Description copied from interface: AsyncConnection

Retrieve an Hbck implementation to fix an HBase cluster. The returned Hbck is not guaranteed to be thread-safe. A new instance should be created by each thread. This is a lightweight operation. Pooling or caching of the returned Hbck instance is not recommended.

The caller is responsible for calling Closeable.close() on the returned Hbck instance.

This will be used mostly by hbck tool. This may only be used to by pass getting registered master from ZK. In situations where ZK is not available or active master is not registered with ZK and user can get master address by other means, master can be explicitly specified.

Specified by:

getHbck in interface AsyncConnection

Parameters:

masterServer - explicit ServerName for master server

Returns:

an Hbck instance for a specified master server

Throws:

IOException