@InterfaceAudience.Private public class ReversedScannerCallable extends ScannerCallable
cConnection, closed, controller, controllerFactory, cursor, heartbeatMessage, id, instantiated, isRegionServerRemote, LOG, LOG_SCANNER_ACTIVITY, LOG_SCANNER_LATENCY_CUTOFF, renew, scan, scanMetrics, scannerIdconnection, location, priority, row, tableName| Constructor and Description |
|---|
ReversedScannerCallable(ClusterConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
RpcControllerFactory rpcFactory) |
ReversedScannerCallable(ClusterConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
RpcControllerFactory rpcFactory,
int replicaId) |
| 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.
|
call, checkIfRegionServerIsRemote, getCaching, getConnection, getCursor, getHRegionInfo, getScan, setCaching, setClose, setRenew, updateResultsMetricsgetExceptionMessageAdditionalDetail, getLocation, getPriority, getRow, getStub, getTableName, setLocation, sleep, throwablepublic ReversedScannerCallable(ClusterConnection connection, TableName tableName, Scan scan, ScanMetrics scanMetrics, RpcControllerFactory rpcFactory)
connection - tableName - scan - scanMetrics - rpcFactory - to create an RpcController to talk to the
regionserverpublic ReversedScannerCallable(ClusterConnection connection, TableName tableName, Scan scan, ScanMetrics scanMetrics, RpcControllerFactory rpcFactory, int replicaId)
connection - tableName - scan - scanMetrics - rpcFactory - to create an RpcController to talk to the
regionserverreplicaId - the replica idpublic void prepare(boolean reload)
throws IOException
RegionServerCallableprepare in interface RetryingCallable<Result[]>prepare in class ScannerCallablereload - force reload of server locationIOExceptionpublic ScannerCallable getScannerCallableForReplica(int id)
getScannerCallableForReplica in class ScannerCallableCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.