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

Fields

Modifier and Type	Field	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 Summary

Constructors

Constructor	Description
ScanResumerImpl()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

state

private AsyncScanSingleRegionRpcRetryingCaller.ScanResumerState state

resp

private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse resp

numberOfCompleteRows

private int numberOfCompleteRows

leaseRenewer

private org.apache.hbase.thirdparty.io.netty.util.Timeout leaseRenewer

Constructor Details

ScanResumerImpl

ScanResumerImpl()

Method Details

resume

public void 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 interface AdvancedScanResultConsumer.ScanResumer

terminate

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

doResume

private void doResume(boolean stopScan)

scheduleRenewLeaseTask

private void scheduleRenewLeaseTask()

tryRenewLease

private void tryRenewLease()

prepare

boolean prepare(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse resp,
 int numberOfCompleteRows)