Package org.apache.hadoop.hbase.client

Class AsyncClientScanner

java.lang.Object

org.apache.hadoop.hbase.client.AsyncClientScanner

@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	Description
private static final class	AsyncClientScanner.OpenScannerResponse

Field Summary

Fields

Modifier and Type	Field	Description
private final AsyncConnectionImpl	conn
private final AdvancedScanResultConsumer	consumer
private final int	maxAttempts
private final AtomicInteger	openScannerTries
private final long	pauseNs
private final long	pauseNsForServerOverloaded
private final Map<String,byte[]>	requestAttributes
private final ScanResultCache	resultCache
private final org.apache.hbase.thirdparty.io.netty.util.Timer	retryTimer
private final long	rpcTimeoutNs
private final Scan	scan
private final ScanMetrics	scanMetrics
private final long	scanTimeoutNs
private final io.opentelemetry.api.trace.Span	span
private final int	startLogErrorsCnt
private final TableName	tableName

Constructor Summary

Constructors

Constructor	Description
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)

Method Summary

Modifier and Type	Method	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 Details

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

pauseNsForServerOverloaded

private final long pauseNsForServerOverloaded

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

span

private final io.opentelemetry.api.trace.Span span

requestAttributes

private final Map<String,byte[]> requestAttributes

openScannerTries

private final AtomicInteger openScannerTries

Constructor Details

AsyncClientScanner

public 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)

Method Details

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()