@InterfaceAudience.Private class MultiServerCallable extends CancellableRegionServerCallable<MultiResponse>
multi
method call going against a single regionserver;
i.e. A RegionServerCallable for the multi call (It is NOT a RegionServerCallable that goes
against multiple regions).Modifier and Type | Field and Description |
---|---|
private boolean |
cellBlock |
private MultiAction |
multiAction |
location, rpcController, stub
Constructor and Description |
---|
MultiServerCallable(ClusterConnection connection,
TableName tableName,
ServerName location,
MultiAction multi,
org.apache.hbase.thirdparty.com.google.protobuf.RpcController rpcController,
int rpcTimeout,
RetryingTimeTracker tracker,
int priority) |
Modifier and Type | Method and Description |
---|---|
HRegionInfo |
getHRegionInfo()
Returns the HRegionInfo for the current region
|
protected HRegionLocation |
getLocation() |
(package private) MultiAction |
getMulti() |
(package private) ServerName |
getServerName() |
private boolean |
isCellBlock() |
void |
prepare(boolean reload)
Prepare by setting up any connections to servers, etc., ahead of call invocation.
|
void |
reset(ServerName location,
MultiAction multiAction) |
protected MultiResponse |
rpcCall()
Run the RPC call.
|
call, cancel, doBulkLoadHFile, doCleanupBulkLoad, doMulti, doPrepareBulkLoad, doScan, isCancelled, setStubByServiceName
doGet, doMutate
getConnection, getExceptionMessageAdditionalDetail, getPriority, getRow, getRpcController, getRpcControllerCellScanner, getStub, getTableName, setLocation, setRpcControllerCellScanner, setStub, sleep, throwable
private MultiAction multiAction
private boolean cellBlock
MultiServerCallable(ClusterConnection connection, TableName tableName, ServerName location, MultiAction multi, org.apache.hbase.thirdparty.com.google.protobuf.RpcController rpcController, int rpcTimeout, RetryingTimeTracker tracker, int priority)
public void reset(ServerName location, MultiAction multiAction)
protected HRegionLocation getLocation()
getLocation
in class RegionServerCallable<MultiResponse,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface>
public HRegionInfo getHRegionInfo()
RegionServerCallable
getHRegionInfo
in class RegionServerCallable<MultiResponse,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface>
MultiAction getMulti()
protected MultiResponse rpcCall() throws Exception
RegionServerCallable
rpcCall
in class RegionServerCallable<MultiResponse,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface>
Exception
private boolean isCellBlock()
public void prepare(boolean reload) throws IOException
RetryingCallable
prepare
in interface RetryingCallable<MultiResponse>
prepare
in class CancellableRegionServerCallable<MultiResponse>
reload
- Set this to true if need to requery locationsIOException
- eServerName getServerName()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.