org.apache.hadoop.hbase.client

Class CompleteScanResultCache

java.lang.Object

org.apache.hadoop.hbase.client.CompleteScanResultCache

All Implemented Interfaces:

ScanResultCache

@InterfaceAudience.Private
class CompleteScanResultCache
extends Object
implements ScanResultCache

A scan result cache that only returns complete result.

Field Summary

Fields

Modifier and Type	Field and Description
private int	numberOfCompleteRows
private List<Result>	partialResults

Fields inherited from interface org.apache.hadoop.hbase.client.ScanResultCache

EMPTY_RESULT_ARRAY

Constructor Summary

Constructors

Constructor and Description
CompleteScanResultCache()

Method Summary

Modifier and Type	Method and Description
Result[]	addAndGet(Result[] results, boolean isHeartbeatMessage) Add the given results to cache and get valid results back.
void	clear() Clear the cached result if any.
private Result	combine()
int	numberOfCompleteRows() Return the number of complete rows.
private Result[]	prependCombined(Result[] results, int length)
private Result[]	updateNumberOfCompleteResultsAndReturn(Result... results)

Methods inherited from class java.lang.Object

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

Field Detail

numberOfCompleteRows

private int numberOfCompleteRows

partialResults

private final List<Result> partialResults

Constructor Detail

CompleteScanResultCache

CompleteScanResultCache()

Method Detail

combine

private Result combine()
                throws IOException

Throws:

IOException

prependCombined

private Result[] prependCombined(Result[] results,
                                 int length)
                          throws IOException

Throws:

IOException

updateNumberOfCompleteResultsAndReturn

private Result[] updateNumberOfCompleteResultsAndReturn(Result... results)

addAndGet

public Result[] addAndGet(Result[] results,
                          boolean isHeartbeatMessage)
                   throws IOException

Description copied from interface: ScanResultCache

Add the given results to cache and get valid results back.

Specified by:

addAndGet in interface ScanResultCache

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

public void 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 interface ScanResultCache

numberOfCompleteRows

public int numberOfCompleteRows()

Description copied from interface: ScanResultCache

Return the number of complete rows. Used to implement limited scan.

Specified by:

numberOfCompleteRows in interface ScanResultCache