static class ClientSmallScanner.SmallScannerCallable extends ScannerCallable
cConnection, 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 |
|---|
ClientSmallScanner.SmallScannerCallable(ClusterConnection connection,
TableName table,
Scan scan,
ScanMetrics scanMetrics,
RpcControllerFactory controllerFactory,
int caching,
int id) |
| 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) |
checkIfRegionServerIsRemote, getCaching, getConnection, getController, getHRegionInfo, getScan, getServerHasMoreResults, hasMoreResultsContext, isHeartbeatMessage, openScanner, prepare, setCaching, setClose, setHasMoreResultsContext, setHeartbeatMessage, setRenew, setServerHasMoreResults, updateResultsMetricsgetExceptionMessageAdditionalDetail, getLocation, getRow, getStub, getTableName, setLocation, setStub, sleep, throwablepublic ClientSmallScanner.SmallScannerCallable(ClusterConnection connection, TableName table, Scan scan, ScanMetrics scanMetrics, RpcControllerFactory controllerFactory, int caching, int id)
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 ScannerCallableCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.