R
- class MultiServerCallable<R> extends RegionServerCallable<MultiResponse> implements Cancellable
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 PayloadCarryingRpcController |
controller |
private MultiAction<R> |
multiAction |
connection, location, row, tableName
Constructor and Description |
---|
MultiServerCallable(ClusterConnection connection,
TableName tableName,
ServerName location,
RpcControllerFactory rpcFactory,
MultiAction<R> multi) |
Modifier and Type | Method and Description |
---|---|
MultiResponse |
call(int callTimeout)
Computes a result, or throws an exception if unable to do so.
|
void |
cancel() |
HRegionInfo |
getHRegionInfo() |
protected HRegionLocation |
getLocation() |
(package private) MultiAction<R> |
getMulti() |
(package private) ServerName |
getServerName() |
boolean |
isCancelled() |
private boolean |
isCellBlock() |
void |
prepare(boolean reload)
Prepare for connection to the server hosting region with row from tablename.
|
getConnection, getExceptionMessageAdditionalDetail, getRow, getStub, getTableName, setLocation, setStub, sleep, throwable
private final MultiAction<R> multiAction
private final boolean cellBlock
private final PayloadCarryingRpcController controller
MultiServerCallable(ClusterConnection connection, TableName tableName, ServerName location, RpcControllerFactory rpcFactory, MultiAction<R> multi)
protected HRegionLocation getLocation()
getLocation
in class RegionServerCallable<MultiResponse>
public HRegionInfo getHRegionInfo()
getHRegionInfo
in class RegionServerCallable<MultiResponse>
MultiAction<R> getMulti()
public MultiResponse call(int callTimeout) throws IOException
RetryingCallable
call
in interface RetryingCallable<MultiResponse>
callTimeout
- - the time available for this call. 0 for infinite.IOException
public void cancel()
cancel
in interface Cancellable
public boolean isCancelled()
isCancelled
in interface Cancellable
private boolean isCellBlock()
public void prepare(boolean reload) throws IOException
RegionServerCallable
prepare
in interface RetryingCallable<MultiResponse>
prepare
in class RegionServerCallable<MultiResponse>
reload
- Set this to true if connection should re-find the regionIOException
- eServerName getServerName()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.