Uses of Interface
org.apache.hadoop.hbase.client.AsyncTable

Packages that use AsyncTable

Package	Description
org.apache.hadoop.hbase
org.apache.hadoop.hbase.client	Provides HBase Client
org.apache.hadoop.hbase.client.coprocessor	Provides client classes for invoking Coprocessor RPC protocols Overview Example Usage

Uses of AsyncTable in org.apache.hadoop.hbase

Methods in org.apache.hadoop.hbase with parameters of type AsyncTable

Modifier and Type	Method and Description
private static Scan	AsyncMetaTableAccessor.getMetaScan(AsyncTable<?> metaTable, int rowUpperLimit)
static CompletableFuture<Optional<HRegionLocation>>	AsyncMetaTableAccessor.getRegionLocation(AsyncTable<?> metaTable, byte[] regionName) Returns the HRegionLocation from meta for the given region
static CompletableFuture<Optional<HRegionLocation>>	AsyncMetaTableAccessor.getRegionLocationWithEncodedName(AsyncTable<?> metaTable, byte[] encodedRegionName) Returns the HRegionLocation from meta for the given encoded region name
static CompletableFuture<List<HRegionLocation>>	AsyncMetaTableAccessor.getTableHRegionLocations(AsyncTable<AdvancedScanResultConsumer> metaTable, TableName tableName) Used to get all region locations for the specific table.
private static CompletableFuture<List<Pair<RegionInfo,ServerName>>>	AsyncMetaTableAccessor.getTableRegionsAndLocations(AsyncTable<AdvancedScanResultConsumer> metaTable, TableName tableName, boolean excludeOfflinedSplitParents) Used to get table regions' info and server.
static CompletableFuture<Optional<TableState>>	AsyncMetaTableAccessor.getTableState(AsyncTable<?> metaTable, TableName tableName)
private static CompletableFuture<Void>	AsyncMetaTableAccessor.scanMeta(AsyncTable<AdvancedScanResultConsumer> metaTable, byte[] startRow, byte[] stopRow, MetaTableAccessor.QueryType type, int maxRows, MetaTableAccessor.Visitor visitor) Performs a scan of META table for given table.
private static CompletableFuture<Void>	AsyncMetaTableAccessor.scanMeta(AsyncTable<AdvancedScanResultConsumer> metaTable, TableName tableName, MetaTableAccessor.QueryType type, MetaTableAccessor.Visitor visitor) Performs a scan of META table for given table.
static CompletableFuture<Boolean>	AsyncMetaTableAccessor.tableExists(AsyncTable<?> metaTable, TableName tableName)

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

Classes in org.apache.hadoop.hbase.client that implement AsyncTable

Modifier and Type	Class and Description
(package private) class	AsyncTableImpl Just a wrapper of RawAsyncTableImpl.
(package private) class	RawAsyncTableImpl The implementation of RawAsyncTable.

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

Modifier and Type	Field and Description
private AsyncTable<AdvancedScanResultConsumer>	RawAsyncHBaseAdmin.metaTable
private AsyncTable<AdvancedScanResultConsumer>	AsyncTableImpl.rawTable
private AsyncTable<AdvancedScanResultConsumer>	AsyncTableResultScanner.rawTable
private AsyncTable<?>	AsyncBufferedMutatorImpl.table

Methods in org.apache.hadoop.hbase.client that return AsyncTable

Modifier and Type	Method and Description
AsyncTable<C>	AsyncTableBuilder.build() Create the AsyncTable instance.
default AsyncTable<AdvancedScanResultConsumer>	AsyncConnection.getTable(TableName tableName) Retrieve an AsyncTable implementation for accessing a table.
default AsyncTable<ScanResultConsumer>	AsyncConnection.getTable(TableName tableName, ExecutorService pool) Retrieve an AsyncTable implementation for accessing a table.

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

Constructor and Description
AsyncBufferedMutatorImpl(org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer periodicalFlushTimer, AsyncTable<?> table, long writeBufferSize, long periodicFlushTimeoutNs, int maxKeyValueSize)
AsyncTableImpl(AsyncConnectionImpl conn, AsyncTable<AdvancedScanResultConsumer> rawTable, ExecutorService pool)
AsyncTableResultScanner(AsyncTable<AdvancedScanResultConsumer> table, Scan scan, long maxCacheSize)

Uses of AsyncTable in org.apache.hadoop.hbase.client.coprocessor

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

Modifier and Type	Method and Description
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<Double>	AsyncAggregationClient.avg(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
private static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> void	AsyncAggregationClient.findMedian(CompletableFuture<R> future, AsyncTable<AdvancedScanResultConsumer> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan, NavigableMap<byte[],S> sumByRegion)
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<R>	AsyncAggregationClient.max(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<R>	AsyncAggregationClient.median(AsyncTable<AdvancedScanResultConsumer> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<R>	AsyncAggregationClient.min(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<Long>	AsyncAggregationClient.rowCount(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<Double>	AsyncAggregationClient.std(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<S>	AsyncAggregationClient.sum(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
private static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<NavigableMap<byte[],S>>	AsyncAggregationClient.sumByRegion(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)