org.apache.hadoop.hbase.client

Class ReversedClientScanner

java.lang.Object

org.apache.hadoop.hbase.client.AbstractClientScanner

org.apache.hadoop.hbase.client.ClientScanner

org.apache.hadoop.hbase.client.ReversedClientScanner

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<Result>, ResultScanner

Direct Known Subclasses:

ClientSmallReversedScanner

@InterfaceAudience.Private
public class ReversedClientScanner
extends ClientScanner

A reversed client scanner which support backward scanning

Field Summary

Fields inherited from class org.apache.hadoop.hbase.client.ClientScanner

cache, caching, callable, caller, closed, conf, currentRegion, lastCellLoadedToCache, lastNext, lastResult, maxScannerResultSize, partialResults, partialResultsRow, pool, primaryOperationTimeout, rpcControllerFactory, scan, scanMetricsPublished, scannerTimeout

Fields inherited from class org.apache.hadoop.hbase.client.AbstractClientScanner

scanMetrics

Constructor Summary

Constructors

Constructor and Description
ReversedClientScanner(org.apache.hadoop.conf.Configuration conf, Scan scan, TableName tableName, ClusterConnection connection, RpcRetryingCallerFactory rpcFactory, RpcControllerFactory controllerFactory, ExecutorService pool, int primaryOperationTimeout) Create a new ReversibleClientScanner for the specified table Note that the passed Scan's start row maybe changed.

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	checkScanStopRow(byte[] startKey)
protected org.apache.hadoop.hbase.client.ScannerCallableWithReplicas	getScannerCallable(byte[] localStartKey, int nbRows, byte[] locateStartRow)
protected boolean	nextScanner(int nbRows, boolean done)

Methods inherited from class org.apache.hadoop.hbase.client.ClientScanner

close, createClosestRowBefore, getCacheSize, getCaching, getConf, getConnection, getMaxResultSize, getPool, getPrimaryOperationTimeout, getResultsToAddToCache, getRetries, getScan, getScannerCallable, getScannerTimeout, getTable, getTableName, getTimestamp, initializeScannerInConstruction, loadCache, next, renewLease, updateLastCellLoadedToCache, writeScanMetrics

Methods inherited from class org.apache.hadoop.hbase.client.AbstractClientScanner

getScanMetrics, initScanMetrics, iterator, next

Methods inherited from class java.lang.Object

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

Constructor Detail

ReversedClientScanner

public ReversedClientScanner(org.apache.hadoop.conf.Configuration conf,
                     Scan scan,
                     TableName tableName,
                     ClusterConnection connection,
                     RpcRetryingCallerFactory rpcFactory,
                     RpcControllerFactory controllerFactory,
                     ExecutorService pool,
                     int primaryOperationTimeout)
                      throws IOException

Create a new ReversibleClientScanner for the specified table Note that the passed Scan's start row maybe changed.

Parameters:

conf -

scan -

tableName -

connection -

pool -

primaryOperationTimeout -

Throws:

IOException

Method Detail

nextScanner

protected boolean nextScanner(int nbRows,
                  boolean done)
                       throws IOException

Overrides:

nextScanner in class ClientScanner

Throws:

IOException

getScannerCallable

protected org.apache.hadoop.hbase.client.ScannerCallableWithReplicas getScannerCallable(byte[] localStartKey,
                                                                            int nbRows,
                                                                            byte[] locateStartRow)

checkScanStopRow

protected boolean checkScanStopRow(byte[] startKey)

Overrides:

checkScanStopRow in class ClientScanner