Package org.apache.hadoop.hbase.client
Class AsyncScanSingleRegionRpcRetryingCaller.ScanResumerImpl
java.lang.Object
org.apache.hadoop.hbase.client.AsyncScanSingleRegionRpcRetryingCaller.ScanResumerImpl
- All Implemented Interfaces:
AdvancedScanResultConsumer.ScanResumer
- Enclosing class:
- AsyncScanSingleRegionRpcRetryingCaller
@Private
final class AsyncScanSingleRegionRpcRetryingCaller.ScanResumerImpl
extends Object
implements AdvancedScanResultConsumer.ScanResumer
-
Field Summary
Modifier and TypeFieldDescriptionprivate org.apache.hbase.thirdparty.io.netty.util.Timeout
private int
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprivate void
doResume
(boolean stopScan) (package private) boolean
prepare
(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse resp, int numberOfCompleteRows) void
resume()
Resume the scan.private void
void
This method is used whenAsyncScanSingleRegionRpcRetryingCaller.ScanControllerImpl.suspend()
had ever been called to get aAsyncScanSingleRegionRpcRetryingCaller.ScanResumerImpl
, but now user stops scan and does not need any more scan results.private void
-
Field Details
-
state
-
resp
-
numberOfCompleteRows
-
leaseRenewer
-
-
Constructor Details
-
ScanResumerImpl
-
-
Method Details
-
resume
Description copied from interface:AdvancedScanResultConsumer.ScanResumer
Resume the scan. You are free to call it multiple time but only the first call will take effect.- Specified by:
resume
in interfaceAdvancedScanResultConsumer.ScanResumer
-
terminate
This method is used whenAsyncScanSingleRegionRpcRetryingCaller.ScanControllerImpl.suspend()
had ever been called to get aAsyncScanSingleRegionRpcRetryingCaller.ScanResumerImpl
, but now user stops scan and does not need any more scan results. -
doResume
-
scheduleRenewLeaseTask
-
tryRenewLease
-
prepare
boolean prepare(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse resp, int numberOfCompleteRows)
-