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, throwableprivate 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
RetryingCallablecall in interface RetryingCallable<MultiResponse>callTimeout - - the time available for this call. 0 for infinite.IOExceptionpublic void cancel()
cancel in interface Cancellablepublic boolean isCancelled()
isCancelled in interface Cancellableprivate boolean isCellBlock()
public void prepare(boolean reload)
throws IOException
RegionServerCallableprepare 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.