Package org.apache.hadoop.hbase.client

Class AsyncScanSingleRegionRpcRetryingCaller

java.lang.Object

org.apache.hadoop.hbase.client.AsyncScanSingleRegionRpcRetryingCaller

@Private
class AsyncScanSingleRegionRpcRetryingCaller
extends Object

Retry caller for scanning a region.

We will modify the Scan object passed in directly. The upper layer should store the reference of this object and use it to open new single region scanners.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	AsyncScanSingleRegionRpcRetryingCaller.ScanControllerImpl
private static enum	AsyncScanSingleRegionRpcRetryingCaller.ScanControllerState
(package private) final class	AsyncScanSingleRegionRpcRetryingCaller.ScanResumerImpl
private static enum	AsyncScanSingleRegionRpcRetryingCaller.ScanResumerState

Field Summary

Fields

Modifier and Type	Field	Description
private final Runnable	completeWhenNoMoreResultsInRegion
protected final AsyncConnectionImpl	conn
private final AdvancedScanResultConsumer	consumer
private final HBaseRpcController	controller
private final List<RetriesExhaustedException.ThrowableWithExtraContext>	exceptions
private final CompletableFuture<Boolean>	future
private boolean	includeNextStartRowWhenError
private final HRegionLocation	loc
private static final org.slf4j.Logger	LOG
private final int	maxAttempts
private long	nextCallSeq
private long	nextCallStartNs
private byte[]	nextStartRowWhenError
private final HBaseServerExceptionPauseManager	pauseManager
private final int	priority
private final boolean	regionServerRemote
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	scannerId
private final long	scannerLeaseTimeoutPeriodNs
private final long	scanTimeoutNs
private final int	startLogErrorsCnt
private final org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface	stub
private int	tries

Constructor Summary

Constructors

Constructor

Description

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)

Method Summary

Modifier and Type	Method	Description
private void	call()
private void	closeScanner()
private void	completeExceptionally(boolean closeScanner)
private void	completeNoMoreResults()
private void	completeOrNext(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse resp, int numberOfCompleteRows)
private void	completeReversedWhenNoMoreResultsInRegion()
private void	completeWhenError(boolean closeScanner)
private void	completeWhenNoMoreResultsInRegion()
private void	completeWithNextStartRow(byte[] row, boolean inclusive)
private long	elapsedMs()
private void	next()
private void	onComplete(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse resp)
private void	onError(Throwable error)
private void	renewLease()
CompletableFuture<Boolean>	start(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse respWhenOpen)	Now we will also fetch some cells along with the scanner id when opening a scanner, so we also need to process the ScanResponse for the open scanner request.
private void	stopScan(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse resp)
private void	updateNextStartRowWhenError(Result result)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

retryTimer

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

scan

private final Scan scan

scanMetrics

private final ScanMetrics scanMetrics

scannerId

private final long scannerId

resultCache

private final ScanResultCache resultCache

consumer

private final AdvancedScanResultConsumer consumer

stub

private final org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub

loc

private final HRegionLocation loc

regionServerRemote

private final boolean regionServerRemote

priority

private final int priority

scannerLeaseTimeoutPeriodNs

private final long scannerLeaseTimeoutPeriodNs

maxAttempts

private final int maxAttempts

scanTimeoutNs

private final long scanTimeoutNs

rpcTimeoutNs

private final long rpcTimeoutNs

startLogErrorsCnt

private final int startLogErrorsCnt

completeWhenNoMoreResultsInRegion

private final Runnable completeWhenNoMoreResultsInRegion

conn

protected final AsyncConnectionImpl conn

future

private final CompletableFuture<Boolean> future

controller

private final HBaseRpcController controller

nextStartRowWhenError

private byte[] nextStartRowWhenError

includeNextStartRowWhenError

private boolean includeNextStartRowWhenError

nextCallStartNs

private long nextCallStartNs

tries

private int tries

exceptions

private final List<RetriesExhaustedException.ThrowableWithExtraContext> exceptions

nextCallSeq

private long nextCallSeq

pauseManager

private final HBaseServerExceptionPauseManager pauseManager

Constructor Details

AsyncScanSingleRegionRpcRetryingCaller

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

Method Details

elapsedMs

private long elapsedMs()

closeScanner

private void closeScanner()

completeExceptionally

private void completeExceptionally(boolean closeScanner)

completeNoMoreResults

private void completeNoMoreResults()

completeWithNextStartRow

private void completeWithNextStartRow(byte[] row,
 boolean inclusive)

completeWhenError

private void completeWhenError(boolean closeScanner)

onError

private void onError(Throwable error)

updateNextStartRowWhenError

private void updateNextStartRowWhenError(Result result)

completeWhenNoMoreResultsInRegion

private void completeWhenNoMoreResultsInRegion()

completeReversedWhenNoMoreResultsInRegion

private void completeReversedWhenNoMoreResultsInRegion()

completeOrNext

private void completeOrNext(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse resp,
 int numberOfCompleteRows)

onComplete

private void onComplete(HBaseRpcController controller,
 org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse resp)

stopScan

private void stopScan(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse resp)

call

private void call()

next

private void next()

renewLease

private void renewLease()

start

public CompletableFuture<Boolean> start(HBaseRpcController controller,
 org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse respWhenOpen)

Now we will also fetch some cells along with the scanner id when opening a scanner, so we also need to process the ScanResponse for the open scanner request. The HBaseRpcController for the open scanner request is also needed because we may have some data in the CellScanner which is contained in the controller.

Returns:

true if we should continue, otherwise false.