Package org.apache.hadoop.hbase.client
Class AsyncScanSingleRegionRpcRetryingCaller.ScanControllerImpl
java.lang.Object
org.apache.hadoop.hbase.client.AsyncScanSingleRegionRpcRetryingCaller.ScanControllerImpl
- All Implemented Interfaces:
AdvancedScanResultConsumer.ScanController
- Enclosing class:
- AsyncScanSingleRegionRpcRetryingCaller
private final class AsyncScanSingleRegionRpcRetryingCaller.ScanControllerImpl
extends Object
implements AdvancedScanResultConsumer.ScanController
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptioncursor()
Get the scan cursor if available.(package private) AsyncScanSingleRegionRpcRetryingCaller.ScanControllerState
destroy()
private void
preCheck()
suspend()
Suspend the scan.void
Terminate the scan.
-
Field Details
-
callerThread
-
cursor
-
state
-
resumer
-
-
Constructor Details
-
ScanControllerImpl
-
-
Method Details
-
preCheck
-
suspend
Description copied from interface:AdvancedScanResultConsumer.ScanController
Suspend the scan.This means we will stop fetching data in background, i.e., will not call onNext any more before you resume the scan.
- Specified by:
suspend
in interfaceAdvancedScanResultConsumer.ScanController
- Returns:
- A resumer used to resume the scan later.
-
terminate
Description copied from interface:AdvancedScanResultConsumer.ScanController
Terminate the scan.This is useful when you have got enough results and want to stop the scan in onNext method, or you want to stop the scan in onHeartbeat method because it has spent too many time.
- Specified by:
terminate
in interfaceAdvancedScanResultConsumer.ScanController
-
destroy
-
cursor
Description copied from interface:AdvancedScanResultConsumer.ScanController
Get the scan cursor if available.- Specified by:
cursor
in interfaceAdvancedScanResultConsumer.ScanController
- Returns:
- The scan cursor.
-