org.apache.hadoop.hbase.client

Class ReversedScannerCallable

java.lang.Object

org.apache.hadoop.hbase.client.RegionServerCallable<Result[]>

org.apache.hadoop.hbase.client.ScannerCallable

org.apache.hadoop.hbase.client.ReversedScannerCallable

All Implemented Interfaces:

RetryingCallable<Result[]>

@InterfaceAudience.Private
public class ReversedScannerCallable
extends ScannerCallable

A reversed ScannerCallable which supports backward scanning.

Field Summary

Fields

Modifier and Type	Field and Description
protected byte[]	locateStartRow The start row for locating regions.

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

cConnection, closed, controller, controllerFactory, heartbeatMessage, id, instantiated, isRegionServerRemote, LOG, LOG_SCANNER_ACTIVITY, LOG_SCANNER_LATENCY_CUTOFF, renew, scanMetrics, scannerId, serverHasMoreResults, serverHasMoreResultsContext

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

connection, location, MIN_WAIT_DEAD_SERVER, row, tableName

Constructor Summary

Constructors

Constructor and Description
ReversedScannerCallable(ClusterConnection connection, TableName tableName, Scan scan, ScanMetrics scanMetrics, byte[] locateStartRow) Deprecated. use ReversedScannerCallable(ClusterConnection, TableName, Scan, ScanMetrics, byte[], RpcControllerFactory )
ReversedScannerCallable(ClusterConnection connection, TableName tableName, Scan scan, ScanMetrics scanMetrics, byte[] locateStartRow, RpcControllerFactory rpcFactory)
ReversedScannerCallable(ClusterConnection connection, TableName tableName, Scan scan, ScanMetrics scanMetrics, byte[] locateStartRow, RpcControllerFactory rpcFactory, int replicaId)

Method Summary

Methods

Modifier and Type	Method and Description
ScannerCallable	getScannerCallableForReplica(int id)
void	prepare(boolean reload) Prepare for connection to the server hosting region with row from tablename.

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

call, checkIfRegionServerIsRemote, getCaching, getConnection, getHRegionInfo, getScan, getServerHasMoreResults, hasMoreResultsContext, isHeartbeatMessage, openScanner, setCaching, setClose, setHasMoreResultsContext, setHeartbeatMessage, setRenew, setServerHasMoreResults, updateResultsMetrics

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

getExceptionMessageAdditionalDetail, getLocation, getRow, getStub, getTableName, setLocation, sleep, throwable

Methods inherited from class java.lang.Object

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

Field Detail

locateStartRow

protected final byte[] locateStartRow

The start row for locating regions. In reversed scanner, may locate the regions for a range of keys when doing ReversedClientScanner.nextScanner(int, boolean)

Constructor Detail

ReversedScannerCallable

public ReversedScannerCallable(ClusterConnection connection,
                       TableName tableName,
                       Scan scan,
                       ScanMetrics scanMetrics,
                       byte[] locateStartRow,
                       RpcControllerFactory rpcFactory)

Parameters:

connection -

tableName -

scan -

scanMetrics -

locateStartRow - The start row for locating regions

rpcFactory - to create an RpcController to talk to the regionserver

ReversedScannerCallable

public ReversedScannerCallable(ClusterConnection connection,
                       TableName tableName,
                       Scan scan,
                       ScanMetrics scanMetrics,
                       byte[] locateStartRow,
                       RpcControllerFactory rpcFactory,
                       int replicaId)

Parameters:

connection -

tableName -

scan -

scanMetrics -

locateStartRow - The start row for locating regions

rpcFactory - to create an RpcController to talk to the regionserver

replicaId - the replica id

ReversedScannerCallable

@Deprecated
public ReversedScannerCallable(ClusterConnection connection,
                                  TableName tableName,
                                  Scan scan,
                                  ScanMetrics scanMetrics,
                                  byte[] locateStartRow)

Deprecated. use ReversedScannerCallable(ClusterConnection, TableName, Scan, ScanMetrics, byte[], RpcControllerFactory )

Method Detail

prepare

public void prepare(boolean reload)
             throws IOException

Description copied from class: RegionServerCallable

Prepare for connection to the server hosting region with row from tablename. Does lookup to find region location and hosting server.

Specified by:

prepare in interface RetryingCallable<Result[]>

Overrides:

prepare in class ScannerCallable

Parameters:

reload - force reload of server location

Throws:

IOException

getScannerCallableForReplica

public ScannerCallable getScannerCallableForReplica(int id)

Overrides:

getScannerCallableForReplica in class ScannerCallable