Uses of Class
org.apache.hadoop.hbase.client.AsyncConnectionImpl

Packages that use AsyncConnectionImpl

Package	Description
org.apache.hadoop.hbase.client	Provides HBase Client
org.apache.hadoop.hbase.client.trace

Uses of AsyncConnectionImpl in org.apache.hadoop.hbase.client

Subclasses of AsyncConnectionImpl in org.apache.hadoop.hbase.client

Modifier and Type	Class	Description
(package private) class	AsyncClusterConnectionImpl	The implementation of AsyncClusterConnection.

Fields in org.apache.hadoop.hbase.client declared as AsyncConnectionImpl

Modifier and Type	Field	Description
private final AsyncConnectionImpl	AsyncBatchRpcRetryingCaller.conn
private final AsyncConnectionImpl	AsyncClientScanner.conn
private final AsyncConnectionImpl	AsyncNonMetaRegionLocator.conn
private final AsyncConnectionImpl	AsyncRegionLocator.conn
private final AsyncConnectionImpl	AsyncRegionServerAdmin.conn
protected final AsyncConnectionImpl	AsyncRpcRetryingCaller.conn
private final AsyncConnectionImpl	AsyncRpcRetryingCallerFactory.conn
private final AsyncConnectionImpl	AsyncScanSingleRegionRpcRetryingCaller.conn
private final AsyncConnectionImpl	AsyncTableRegionLocatorImpl.conn
private final AsyncConnectionImpl	CatalogReplicaLoadBalanceSimpleSelector.conn
private final AsyncConnectionImpl	ConnectionOverAsyncConnection.conn
private final AsyncConnectionImpl	RawAsyncTableImpl.conn
private final AsyncConnectionImpl	RegionCoprocessorRpcChannelImpl.conn
private final AsyncConnectionImpl	TableOverAsyncTable.conn
private final AsyncConnectionImpl	RawAsyncHBaseAdmin.connection

Methods in org.apache.hadoop.hbase.client with parameters of type AsyncConnectionImpl

Modifier and Type	Method	Description
static CatalogReplicaLoadBalanceSelector	CatalogReplicaLoadBalanceSelectorFactory.createSelector(String replicaSelectorClass, TableName tableName, AsyncConnectionImpl conn, IntSupplier getReplicaCount)	Create a CatalogReplicaLoadBalanceReplicaSelector based on input config.

Constructors in org.apache.hadoop.hbase.client with parameters of type AsyncConnectionImpl

Modifier	Constructor	Description
	AsyncAdminRequestRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, AsyncConnectionImpl conn, int priority, long pauseNs, long pauseNsForServerOverloaded, int maxAttempts, long operationTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt, ServerName serverName, AsyncAdminRequestRetryingCaller.Callable<T> callable)
	AsyncBatchRpcRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, AsyncConnectionImpl conn, TableName tableName, List<? extends Row> actions, long pauseNs, long pauseNsForServerOverloaded, int maxAttempts, long operationTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt, Map<String,byte[]> requestAttributes)
	AsyncClientScanner(Scan scan, AdvancedScanResultConsumer consumer, TableName tableName, AsyncConnectionImpl conn, org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, long pauseNs, long pauseNsForServerOverloaded, int maxAttempts, long scanTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt, Map<String,byte[]> requestAttributes)
	AsyncMasterRequestRpcRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, AsyncConnectionImpl conn, AsyncMasterRequestRpcRetryingCaller.Callable<T> callable, int priority, long pauseNs, long pauseNsForServerOverloaded, int maxRetries, long operationTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt)
(package private)	AsyncNonMetaRegionLocator(AsyncConnectionImpl conn)
(package private)	AsyncRegionLocator(AsyncConnectionImpl conn, org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer retryTimer)
(package private)	AsyncRegionServerAdmin(ServerName server, AsyncConnectionImpl conn)
	AsyncRpcRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, AsyncConnectionImpl conn, int priority, long pauseNs, long pauseNsForServerOverloaded, int maxAttempts, long operationTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt, Map<String,byte[]> requestAttributes)
	AsyncRpcRetryingCallerFactory(AsyncConnectionImpl conn, org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer)
	AsyncScanSingleRegionRpcRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, AsyncConnectionImpl conn, Scan scan, ScanMetrics scanMetrics, long scannerId, ScanResultCache resultCache, AdvancedScanResultConsumer consumer, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub, HRegionLocation loc, boolean isRegionServerRemote, int priority, long scannerLeaseTimeoutPeriodNs, long pauseNs, long pauseNsForServerOverloaded, int maxAttempts, long scanTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt, Map<String,byte[]> requestAttributes)
	AsyncServerRequestRpcRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, AsyncConnectionImpl conn, long pauseNs, long pauseNsForServerOverloaded, int maxAttempts, long operationTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt, ServerName serverName, AsyncServerRequestRpcRetryingCaller.Callable<T> callable)
	AsyncSingleRequestRpcRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, AsyncConnectionImpl conn, TableName tableName, byte[] row, int replicaId, RegionLocateType locateType, AsyncSingleRequestRpcRetryingCaller.Callable<T> callable, int priority, long pauseNs, long pauseNsForServerOverloaded, int maxAttempts, long operationTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt, Map<String,byte[]> requestAttributes)
	AsyncTableRegionLocatorImpl(TableName tableName, AsyncConnectionImpl conn)
(package private)	CatalogReplicaLoadBalanceSimpleSelector(TableName tableName, AsyncConnectionImpl conn, IntSupplier getNumOfReplicas)
(package private)	ConnectionOverAsyncConnection(AsyncConnectionImpl conn)
(package private)	RawAsyncHBaseAdmin(AsyncConnectionImpl connection, org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer retryTimer, AsyncAdminBuilderBase builder)
(package private)	RawAsyncTableImpl(AsyncConnectionImpl conn, org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, AsyncTableBuilderBase<?> builder)
(package private)	RegionCoprocessorRpcChannel(AsyncConnectionImpl conn, TableName tableName, RegionInfo region, byte[] row, long rpcTimeoutNs, long operationTimeoutNs)
(package private)	RegionCoprocessorRpcChannelImpl(AsyncConnectionImpl conn, TableName tableName, RegionInfo region, byte[] row, long rpcTimeoutNs, long operationTimeoutNs)
(package private)	TableOverAsyncTable(AsyncConnectionImpl conn, AsyncTable<?> table, IOExceptionSupplier<ExecutorService> poolSupplier)

Uses of AsyncConnectionImpl in org.apache.hadoop.hbase.client.trace

Methods in org.apache.hadoop.hbase.client.trace with parameters of type AsyncConnectionImpl

Modifier and Type	Method	Description
(package private) static void	ConnectionSpanBuilder.populateConnectionAttributes(Map<io.opentelemetry.api.common.AttributeKey<?>,Object> attributes, AsyncConnectionImpl conn)	Static utility method that performs the primary logic of this builder.

Constructors in org.apache.hadoop.hbase.client.trace with parameters of type AsyncConnectionImpl

Modifier	Constructor	Description
	ConnectionSpanBuilder(AsyncConnectionImpl conn)
	TableOperationSpanBuilder(AsyncConnectionImpl conn)
	TableSpanBuilder(AsyncConnectionImpl conn)