Package org.apache.hadoop.hbase.client
Class CompleteScanResultCache
java.lang.Object
org.apache.hadoop.hbase.client.CompleteScanResultCache
- All Implemented Interfaces:
ScanResultCache
A scan result cache that only returns complete result.
-
Field Summary
Modifier and TypeFieldDescriptionprivate int
Fields inherited from interface org.apache.hadoop.hbase.client.ScanResultCache
EMPTY_RESULT_ARRAY
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionResult[]
Add the given results to cache and get valid results back.void
clear()
Clear the cached result if any.private Result
combine()
int
Return the number of complete rows.private Result[]
prependCombined
(Result[] results, int length) private Result[]
updateNumberOfCompleteResultsAndReturn
(Result... results)
-
Field Details
-
numberOfCompleteRows
-
partialResults
-
-
Constructor Details
-
CompleteScanResultCache
-
-
Method Details
-
combine
- Throws:
IOException
-
prependCombined
- Throws:
IOException
-
updateNumberOfCompleteResultsAndReturn
-
addAndGet
Description copied from interface:ScanResultCache
Add the given results to cache and get valid results back.- Specified by:
addAndGet
in interfaceScanResultCache
- Parameters:
results
- the results of a scan next. Must not be null.isHeartbeatMessage
- indicate whether the results is gotten from a heartbeat response.- Returns:
- valid results, never null.
- Throws:
IOException
-
clear
Description copied from interface:ScanResultCache
Clear the cached result if any. Called when scan error and we will start from a start of a row again.- Specified by:
clear
in interfaceScanResultCache
-
numberOfCompleteRows
Description copied from interface:ScanResultCache
Return the number of complete rows. Used to implement limited scan.- Specified by:
numberOfCompleteRows
in interfaceScanResultCache
-