@InterfaceAudience.Private public class ReversedScannerCallable extends ScannerCallable
Modifier and Type | Field and Description |
---|---|
protected byte[] |
locateStartRow
The start row for locating regions.
|
cConnection, closed, controller, controllerFactory, heartbeatMessage, id, instantiated, isRegionServerRemote, LOG, LOG_SCANNER_ACTIVITY, LOG_SCANNER_LATENCY_CUTOFF, renew, scanMetrics, scannerId, serverHasMoreResults, serverHasMoreResultsContext
connection, location, row, tableName
Constructor and Description |
---|
ReversedScannerCallable(ClusterConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
byte[] locateStartRow)
|
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) |
Modifier and Type | Method and Description |
---|---|
ScannerCallable |
getScannerCallableForReplica(int id) |
private List<HRegionLocation> |
locateRegionsInRange(byte[] startKey,
byte[] endKey,
boolean reload)
Get the corresponding regions for an arbitrary range of keys.
|
void |
prepare(boolean reload)
Prepare for connection to the server hosting region with row from tablename.
|
call, checkIfRegionServerIsRemote, getCaching, getConnection, getController, getHRegionInfo, getScan, getServerHasMoreResults, hasMoreResultsContext, isHeartbeatMessage, openScanner, setCaching, setClose, setHasMoreResultsContext, setHeartbeatMessage, setRenew, setServerHasMoreResults, updateResultsMetrics
getExceptionMessageAdditionalDetail, getLocation, getRow, getStub, getTableName, setLocation, setStub, sleep, throwable
protected final byte[] locateStartRow
ReversedClientScanner.nextScanner(int, boolean)
public ReversedScannerCallable(ClusterConnection connection, TableName tableName, Scan scan, ScanMetrics scanMetrics, byte[] locateStartRow, RpcControllerFactory rpcFactory)
connection
- tableName
- scan
- scanMetrics
- locateStartRow
- The start row for locating regionsrpcFactory
- to create an
RpcController
to talk to the regionserverpublic ReversedScannerCallable(ClusterConnection connection, TableName tableName, Scan scan, ScanMetrics scanMetrics, byte[] locateStartRow, RpcControllerFactory rpcFactory, int replicaId)
connection
- tableName
- scan
- scanMetrics
- locateStartRow
- The start row for locating regionsrpcFactory
- to create an
RpcController
to talk to the regionserverreplicaId
- the replica id@Deprecated public ReversedScannerCallable(ClusterConnection connection, TableName tableName, Scan scan, ScanMetrics scanMetrics, byte[] locateStartRow)
public void prepare(boolean reload) throws IOException
RegionServerCallable
prepare
in interface RetryingCallable<Result[]>
prepare
in class ScannerCallable
reload
- force reload of server locationIOException
private List<HRegionLocation> locateRegionsInRange(byte[] startKey, byte[] endKey, boolean reload) throws IOException
startKey
- Starting row in range, inclusiveendKey
- Ending row in range, exclusivereload
- force reload of server locationIOException
public ScannerCallable getScannerCallableForReplica(int id)
getScannerCallableForReplica
in class ScannerCallable
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.