org.apache.hadoop.hbase.client

Class AllowPartialScanResultCache

java.lang.Object

org.apache.hadoop.hbase.client.AllowPartialScanResultCache

All Implemented Interfaces:

ScanResultCache

@InterfaceAudience.Private
class AllowPartialScanResultCache
extends Object
implements ScanResultCache

A ScanResultCache that may return partial result.

As we can only scan from the starting of a row when error, so here we also implement the logic that skips the cells that have already been returned.

Field Summary

Fields

Modifier and Type	Field and Description
private Cell	lastCell
private boolean	lastResultPartial
private int	numberOfCompleteRows

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

EMPTY_RESULT_ARRAY

Constructor Summary

Constructors

Constructor and Description
AllowPartialScanResultCache()

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.
int	numberOfCompleteRows() Return the number of complete rows.
private void	recordLastResult(Result result)

Methods inherited from class java.lang.Object

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

Field Detail

lastCell

private Cell lastCell

lastResultPartial

private boolean lastResultPartial

numberOfCompleteRows

private int numberOfCompleteRows

Constructor Detail

AllowPartialScanResultCache

AllowPartialScanResultCache()

Method Detail

recordLastResult

private void recordLastResult(Result result)

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