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

Packages that use AdvancedScanResultConsumer

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 AdvancedScanResultConsumer in org.apache.hadoop.hbase

Classes in org.apache.hadoop.hbase that implement AdvancedScanResultConsumer

Modifier and Type	Class and Description
private static class	AsyncMetaTableAccessor.MetaTableScanResultConsumer

Method parameters in org.apache.hadoop.hbase with type arguments of type AdvancedScanResultConsumer

Modifier and Type	Method and Description
static CompletableFuture<List<HRegionLocation>>	AsyncMetaTableAccessor.getTableHRegionLocations(AsyncTable<AdvancedScanResultConsumer> metaTable, Optional<TableName> tableName) Used to get all region locations for the specific table.
private static CompletableFuture<List<Pair<RegionInfo,ServerName>>>	AsyncMetaTableAccessor.getTableRegionsAndLocations(AsyncTable<AdvancedScanResultConsumer> metaTable, Optional<TableName> tableName, boolean excludeOfflinedSplitParents) Used to get table regions' info and server.
private static CompletableFuture<Void>	AsyncMetaTableAccessor.scanMeta(AsyncTable<AdvancedScanResultConsumer> metaTable, Optional<byte[]> startRow, Optional<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, Optional<TableName> tableName, MetaTableAccessor.QueryType type, MetaTableAccessor.Visitor visitor) Performs a scan of META table for given table.

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

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

Modifier and Type	Class and Description
(package private) class	AsyncTableResultScanner The ResultScanner implementation for AsyncTable.

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

Modifier and Type	Field and Description
private AdvancedScanResultConsumer	AsyncClientScanner.consumer
private AdvancedScanResultConsumer	AsyncScanSingleRegionRpcRetryingCaller.consumer
private AdvancedScanResultConsumer	AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder.consumer

Fields in org.apache.hadoop.hbase.client with type parameters of type AdvancedScanResultConsumer

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

Methods in org.apache.hadoop.hbase.client that return types with arguments of type AdvancedScanResultConsumer

Modifier and Type	Method and Description
default AsyncTable<AdvancedScanResultConsumer>	AsyncConnection.getTable(TableName tableName) Retrieve an AsyncTable implementation for accessing a table.
AsyncTableBuilder<AdvancedScanResultConsumer>	AsyncConnectionImpl.getTableBuilder(TableName tableName)
AsyncTableBuilder<AdvancedScanResultConsumer>	AsyncConnection.getTableBuilder(TableName tableName) Returns an AsyncTableBuilder for creating AsyncTable.

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

Modifier and Type	Method and Description
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder	AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder.consumer(AdvancedScanResultConsumer consumer)
void	RawAsyncTableImpl.scan(Scan scan, AdvancedScanResultConsumer consumer)

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

Constructor and Description
AsyncClientScanner(Scan scan, AdvancedScanResultConsumer consumer, TableName tableName, AsyncConnectionImpl conn, org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, long pauseNs, int maxAttempts, long scanTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt)
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, long scannerLeaseTimeoutPeriodNs, long pauseNs, int maxAttempts, long scanTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt)

Constructor parameters in org.apache.hadoop.hbase.client with type arguments of type AdvancedScanResultConsumer

Constructor and Description
AsyncTableImpl(AsyncConnectionImpl conn, AsyncTable<AdvancedScanResultConsumer> rawTable, ExecutorService pool)
AsyncTableResultScanner(AsyncTable<AdvancedScanResultConsumer> table, Scan scan, long maxCacheSize)

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

Method parameters in org.apache.hadoop.hbase.client.coprocessor with type arguments of type AdvancedScanResultConsumer

Modifier and Type	Method and Description
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.median(AsyncTable<AdvancedScanResultConsumer> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)