org.apache.hadoop.hbase.client

Class ClientSmallReversedScanner

java.lang.Object

org.apache.hadoop.hbase.client.AbstractClientScanner

org.apache.hadoop.hbase.client.ClientScanner

org.apache.hadoop.hbase.client.ReversedClientScanner

org.apache.hadoop.hbase.client.ClientSmallReversedScanner

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.lang.Iterable<Result>, ResultScanner

@InterfaceAudience.Private
public class ClientSmallReversedScanner
extends ReversedClientScanner

Client scanner for small reversed scan. Generally, only one RPC is called to fetch the scan results, unless the results cross multiple regions or the row count of results exceed the caching.

For small scan, it will get better performance than ReversedClientScanner

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	ClientSmallReversedScanner.SmallReversedScannerCallableFactory

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
ClientSmallReversedScanner(Configuration conf, Scan scan, TableName tableName, ClusterConnection connection, RpcRetryingCallerFactory rpcFactory, RpcControllerFactory controllerFactory, java.util.concurrent.ExecutorService pool, int primaryOperationTimeout) Create a new ReversibleClientScanner for the specified table.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the scanner and releases any resources it has allocated
protected void	initializeScannerInConstruction()
protected void	loadCache() Contact the servers to load more Results in the cache.
Result	next() Grab the next row's worth of values.
protected void	setScannerCallableFactory(ClientSmallReversedScanner.SmallReversedScannerCallableFactory callableFactory)

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

checkScanStopRow, getScannerCallable, nextScanner

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

createClosestRowBefore, getCacheSize, getCaching, getConf, getConnection, getMaxResultSize, getPool, getPrimaryOperationTimeout, getResultsToAddToCache, getRetries, getScan, getScannerCallable, getScannerTimeout, getTable, getTableName, getTimestamp, 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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

ClientSmallReversedScanner

public ClientSmallReversedScanner(Configuration conf,
                                  Scan scan,
                                  TableName tableName,
                                  ClusterConnection connection,
                                  RpcRetryingCallerFactory rpcFactory,
                                  RpcControllerFactory controllerFactory,
                                  java.util.concurrent.ExecutorService pool,
                                  int primaryOperationTimeout)
                           throws java.io.IOException

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

Parameters:

conf - The Configuration to use.

scan - Scan to use in this scanner

tableName - The table that we wish to rangeGet

connection - Connection identifying the cluster

rpcFactory - Factory used to create the RpcRetryingCaller

controllerFactory - Factory used to access RPC payloads

pool - Threadpool for RPC threads

primaryOperationTimeout - Call timeout

Throws:

java.io.IOException - If the remote call fails

Method Detail

next

public Result next()
            throws java.io.IOException

Description copied from interface: ResultScanner

Grab the next row's worth of values. The scanner will return a Result.

Specified by:

next in interface ResultScanner

Overrides:

next in class ClientScanner

Returns:

Result object if there is another row, null if the scanner is exhausted.

Throws:

java.io.IOException - e

loadCache

protected void loadCache()
                  throws java.io.IOException

Description copied from class: ClientScanner

Contact the servers to load more Results in the cache.

Overrides:

loadCache in class ClientScanner

Throws:

java.io.IOException

initializeScannerInConstruction

protected void initializeScannerInConstruction()
                                        throws java.io.IOException

Overrides:

initializeScannerInConstruction in class ClientScanner

Throws:

java.io.IOException

close

public void close()

Description copied from interface: ResultScanner

Closes the scanner and releases any resources it has allocated

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface ResultScanner

Overrides:

close in class ClientScanner

setScannerCallableFactory

protected void setScannerCallableFactory(ClientSmallReversedScanner.SmallReversedScannerCallableFactory callableFactory)