static class ClientSmallReversedScanner.SmallReversedScannerCallable extends ReversedScannerCallable
locateStartRowcConnection, closed, controller, controllerFactory, heartbeatMessage, id, instantiated, isRegionServerRemote, LOG, LOG_SCANNER_ACTIVITY, LOG_SCANNER_LATENCY_CUTOFF, renew, scanMetrics, scannerId, serverHasMoreResults, serverHasMoreResultsContextconnection, location, row, tableName| Constructor and Description |
|---|
ClientSmallReversedScanner.SmallReversedScannerCallable(ClusterConnection connection,
TableName table,
Scan scan,
ScanMetrics scanMetrics,
byte[] locateStartRow,
RpcControllerFactory controllerFactory,
int caching,
int replicaId) |
| Modifier and Type | Method and Description |
|---|---|
Result[] |
call(int timeout)
Computes a result, or throws an exception if unable to do so.
|
ScannerCallable |
getScannerCallableForReplica(int id) |
preparecheckIfRegionServerIsRemote, getCaching, getConnection, getController, getHRegionInfo, getScan, getServerHasMoreResults, hasMoreResultsContext, isHeartbeatMessage, openScanner, setCaching, setClose, setHasMoreResultsContext, setHeartbeatMessage, setRenew, setServerHasMoreResults, updateResultsMetricsgetExceptionMessageAdditionalDetail, getLocation, getRow, getStub, getTableName, setLocation, setStub, sleep, throwablepublic ClientSmallReversedScanner.SmallReversedScannerCallable(ClusterConnection connection, TableName table, Scan scan, ScanMetrics scanMetrics, byte[] locateStartRow, RpcControllerFactory controllerFactory, int caching, int replicaId)
public Result[] call(int timeout) throws IOException
RetryingCallablecall in interface RetryingCallable<Result[]>call in class ScannerCallabletimeout - - the time available for this call. 0 for infinite.IOExceptionpublic ScannerCallable getScannerCallableForReplica(int id)
getScannerCallableForReplica in class ReversedScannerCallableCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.