org.apache.hadoop.hbase.client

Class AsyncClientScanner

java.lang.Object

org.apache.hadoop.hbase.client.AsyncClientScanner

@InterfaceAudience.Private
class AsyncClientScanner
extends Object

The asynchronous client scanner implementation.

Here we will call OpenScanner first and use the returned scannerId to create a AsyncScanSingleRegionRpcRetryingCaller to do the real scan operation. The return value of AsyncScanSingleRegionRpcRetryingCaller will tell us whether open a new scanner or finish scan.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	AsyncClientScanner.OpenScannerResponse

Field Summary

Fields

Modifier and Type	Field and Description
private AsyncConnectionImpl	conn
private AdvancedScanResultConsumer	consumer
private int	maxAttempts
private AtomicInteger	openScannerTries
private long	pauseForCQTBENs
private long	pauseNs
private ScanResultCache	resultCache
private org.apache.hbase.thirdparty.io.netty.util.Timer	retryTimer
private long	rpcTimeoutNs
private Scan	scan
private ScanMetrics	scanMetrics
private long	scanTimeoutNs
private int	startLogErrorsCnt
private TableName	tableName

Constructor Summary

Constructors

Constructor and Description
AsyncClientScanner(Scan scan, AdvancedScanResultConsumer consumer, TableName tableName, AsyncConnectionImpl conn, org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, long pauseNs, long pauseForCQTBENs, int maxAttempts, long scanTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt)

Method Summary

Modifier and Type	Method and Description
private CompletableFuture<AsyncClientScanner.OpenScannerResponse>	callOpenScanner(HBaseRpcController controller, HRegionLocation loc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub)
private long	getPrimaryTimeoutNs()
private void	openScanner()
private CompletableFuture<AsyncClientScanner.OpenScannerResponse>	openScanner(int replicaId)
void	start()
private void	startScan(AsyncClientScanner.OpenScannerResponse resp)

Methods inherited from class java.lang.Object

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

Field Detail

scan

private final Scan scan

scanMetrics

private final ScanMetrics scanMetrics

consumer

private final AdvancedScanResultConsumer consumer

tableName

private final TableName tableName

conn

private final AsyncConnectionImpl conn

retryTimer

private final org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer

pauseNs

private final long pauseNs

pauseForCQTBENs

private final long pauseForCQTBENs

maxAttempts

private final int maxAttempts

scanTimeoutNs

private final long scanTimeoutNs

rpcTimeoutNs

private final long rpcTimeoutNs

startLogErrorsCnt

private final int startLogErrorsCnt

resultCache

private final ScanResultCache resultCache

openScannerTries

private final AtomicInteger openScannerTries

Constructor Detail

AsyncClientScanner

public AsyncClientScanner(Scan scan,
                          AdvancedScanResultConsumer consumer,
                          TableName tableName,
                          AsyncConnectionImpl conn,
                          org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer,
                          long pauseNs,
                          long pauseForCQTBENs,
                          int maxAttempts,
                          long scanTimeoutNs,
                          long rpcTimeoutNs,
                          int startLogErrorsCnt)

Method Detail

callOpenScanner

private CompletableFuture<AsyncClientScanner.OpenScannerResponse> callOpenScanner(HBaseRpcController controller,
                                                                                  HRegionLocation loc,
                                                                                  org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub)

startScan

private void startScan(AsyncClientScanner.OpenScannerResponse resp)

openScanner

private CompletableFuture<AsyncClientScanner.OpenScannerResponse> openScanner(int replicaId)

getPrimaryTimeoutNs

private long getPrimaryTimeoutNs()

openScanner

private void openScanner()

start

public void start()