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 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 Summary

Constructors

Modifier	Constructor and Description
private	ScanResumerImpl()

Method Summary

Modifier and Type	Method and Description
(package private) boolean	prepare(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse resp, int numberOfCompleteRows)
void	resume() Resume the scan.
private void	scheduleRenewLeaseTask()
private void	tryRenewLease()

Methods inherited from class java.lang.Object

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

Field Detail

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 Detail

ScanResumerImpl

private ScanResumerImpl()

Method Detail

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

scheduleRenewLeaseTask

private void scheduleRenewLeaseTask()

tryRenewLease

private void tryRenewLease()

prepare

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