@InterfaceAudience.Private final class AsyncScanSingleRegionRpcRetryingCaller.ScanResumerImpl extends Object implements AdvancedScanResultConsumer.ScanResumer
Modifier and Type | Field and Description |
---|---|
private org.apache.hbase.thirdparty.io.netty.util.Timeout |
leaseRenewer |
private int |
numberOfCompleteRows |
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse |
resp |
private AsyncScanSingleRegionRpcRetryingCaller.ScanResumerState |
state |
Constructor and Description |
---|
ScanResumerImpl() |
Modifier and Type | Method and Description |
---|---|
private 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 |
scheduleRenewLeaseTask() |
void |
terminate()
This method is used when
AsyncScanSingleRegionRpcRetryingCaller.ScanControllerImpl.suspend() had ever been called to get a
AsyncScanSingleRegionRpcRetryingCaller.ScanResumerImpl , but now user stops scan and does not need any more scan results. |
private void |
tryRenewLease() |
private AsyncScanSingleRegionRpcRetryingCaller.ScanResumerState state
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse resp
private int numberOfCompleteRows
private org.apache.hbase.thirdparty.io.netty.util.Timeout leaseRenewer
ScanResumerImpl()
public void resume()
AdvancedScanResultConsumer.ScanResumer
resume
in interface AdvancedScanResultConsumer.ScanResumer
public void terminate()
AsyncScanSingleRegionRpcRetryingCaller.ScanControllerImpl.suspend()
had ever been called to get a
AsyncScanSingleRegionRpcRetryingCaller.ScanResumerImpl
, but now user stops scan and does not need any more scan results.private void doResume(boolean stopScan)
private void scheduleRenewLeaseTask()
private void tryRenewLease()
boolean prepare(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse resp, int numberOfCompleteRows)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.