org.apache.hadoop.hbase.client

Class AsyncScanSingleRegionRpcRetryingCaller

java.lang.Object

org.apache.hadoop.hbase.client.AsyncScanSingleRegionRpcRetryingCaller

@InterfaceAudience.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 and Description
private class	AsyncScanSingleRegionRpcRetryingCaller.ScanControllerImpl
private static class	AsyncScanSingleRegionRpcRetryingCaller.ScanControllerState
private class	AsyncScanSingleRegionRpcRetryingCaller.ScanResumerImpl
private static class	AsyncScanSingleRegionRpcRetryingCaller.ScanResumerState

Field Summary

Fields

Modifier and Type	Field and Description
private Runnable	completeWhenNoMoreResultsInRegion
private AdvancedScanResultConsumer	consumer
private HBaseRpcController	controller
private List<RetriesExhaustedException.ThrowableWithExtraContext>	exceptions
private CompletableFuture<Boolean>	future
private boolean	includeNextStartRowWhenError
private HRegionLocation	loc
private static org.slf4j.Logger	LOG
private int	maxAttempts
private long	nextCallSeq
private long	nextCallStartNs
private byte[]	nextStartRowWhenError
private long	pauseNs
private boolean	regionServerRemote
private ScanResultCache	resultCache
private org.apache.hbase.thirdparty.io.netty.util.Timer	retryTimer
private long	rpcTimeoutNs
private Scan	scan
private ScanMetrics	scanMetrics
private long	scannerId
private long	scannerLeaseTimeoutPeriodNs
private long	scanTimeoutNs
private int	startLogErrorsCnt
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface	stub
private int	tries

Constructor Summary

Constructors

Constructor and 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, long scannerLeaseTimeoutPeriodNs, long pauseNs, int maxAttempts, long scanTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt)

Method Summary

Modifier and Type	Method and 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 long	remainingTimeNs()
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	updateNextStartRowWhenError(Result result)

Methods inherited from class java.lang.Object

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

Field Detail

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

scannerLeaseTimeoutPeriodNs

private final long scannerLeaseTimeoutPeriodNs

pauseNs

private final long pauseNs

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

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

Constructor Detail

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,
                                              long scannerLeaseTimeoutPeriodNs,
                                              long pauseNs,
                                              int maxAttempts,
                                              long scanTimeoutNs,
                                              long rpcTimeoutNs,
                                              int startLogErrorsCnt)

Method Detail

elapsedMs

private long elapsedMs()

remainingTimeNs

private long remainingTimeNs()

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)

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.