class RpcRetryingCallerWithReadReplicas.ReplicaRegionServerCallable extends CancellableRegionServerCallable<Result>
Modifier and Type | Field and Description |
---|---|
(package private) int |
id |
location, rpcController, stub
Constructor and Description |
---|
ReplicaRegionServerCallable(int id,
HRegionLocation location) |
Modifier and Type | Method and Description |
---|---|
void |
prepare(boolean reload)
Two responsibilities
- if the call is already completed (by another replica) stops the retries.
|
protected Result |
rpcCall()
Run the RPC call.
|
call, cancel, doBulkLoadHFile, doCleanupBulkLoad, doMulti, doPrepareBulkLoad, doScan, isCancelled, setStubByServiceName
doGet, doMutate
getConnection, getExceptionMessageAdditionalDetail, getHRegionInfo, getLocation, getPriority, getRow, getRpcController, getRpcControllerCellScanner, getStub, getTableName, setLocation, setRpcControllerCellScanner, setStub, sleep, throwable
final int id
public ReplicaRegionServerCallable(int id, HRegionLocation location)
public void prepare(boolean reload) throws IOException
prepare
in interface RetryingCallable<Result>
prepare
in class CancellableRegionServerCallable<Result>
reload
- Set this to true if need to requery locationsIOException
- eprotected Result rpcCall() throws Exception
RegionServerCallable
rpcCall
in class RegionServerCallable<Result,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface>
Exception
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.