Package org.apache.hadoop.hbase.client

Class MultiServerCallable

java.lang.Object

org.apache.hadoop.hbase.client.RegionServerCallable<T,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface>

org.apache.hadoop.hbase.client.ClientServiceCallable<T>

org.apache.hadoop.hbase.client.CancellableRegionServerCallable<MultiResponse>

org.apache.hadoop.hbase.client.MultiServerCallable

All Implemented Interfaces:

Cancellable, RetryingCallable<MultiResponse>

@Private
class MultiServerCallable
extends CancellableRegionServerCallable<MultiResponse>

Callable that handles the 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).

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	cellBlock
private MultiAction	multiAction

Fields inherited from class org.apache.hadoop.hbase.client.RegionServerCallable

location, requestAttributes, rpcController, stub

Constructor Summary

Constructors

Constructor	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, Map<String,byte[]> requestAttributes)

Method Summary

Modifier and Type	Method	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.

Methods inherited from class org.apache.hadoop.hbase.client.CancellableRegionServerCallable

call, cancel, doBulkLoadHFile, doCleanupBulkLoad, doMulti, doPrepareBulkLoad, doScan, getTracker, isCancelled, setStubByServiceName

Methods inherited from class org.apache.hadoop.hbase.client.ClientServiceCallable

doGet, doMutate

Methods inherited from class org.apache.hadoop.hbase.client.RegionServerCallable

getConnection, getExceptionMessageAdditionalDetail, getPriority, getRow, getRpcController, getRpcControllerCellScanner, getStub, getTableName, setLocation, setRpcControllerCellScanner, setStub, sleep, throwable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

multiAction

private MultiAction multiAction

cellBlock

private boolean cellBlock

Constructor Details

MultiServerCallable

MultiServerCallable(ClusterConnection connection,
 TableName tableName,
 ServerName location,
 MultiAction multi,
 org.apache.hbase.thirdparty.com.google.protobuf.RpcController rpcController,
 int rpcTimeout,
 RetryingTimeTracker tracker,
 int priority,
 Map<String,byte[]> requestAttributes)

Method Details

reset

public void reset(ServerName location,
 MultiAction multiAction)

getLocation

protected HRegionLocation getLocation()

Overrides:

getLocation in class RegionServerCallable<MultiResponse,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface>

getHRegionInfo

public HRegionInfo getHRegionInfo()

Description copied from class: RegionServerCallable

Returns the HRegionInfo for the current region

Overrides:

getHRegionInfo in class RegionServerCallable<MultiResponse,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface>

getMulti

MultiAction getMulti()

rpcCall

protected MultiResponse rpcCall()
                         throws Exception

Description copied from class: RegionServerCallable

Run the RPC call. Implement this method. To get at the rpcController that has been created and configured to make this rpc call, use getRpcController(). We are trying to contain rpcController references so we don't pollute codebase with protobuf references; keep the protobuf references contained and only present in a few classes rather than all about the code base.

Specified by:

rpcCall in class RegionServerCallable<MultiResponse,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface>

Throws:

Exception

isCellBlock

private boolean isCellBlock()

Returns:

True if we should send data in cellblocks. This is an expensive call. Cache the result if you can rather than call each time.

prepare

public void prepare(boolean reload)
             throws IOException

Description copied from interface: RetryingCallable

Prepare by setting up any connections to servers, etc., ahead of call invocation. TODO: We call prepare before EVERY call. Seems wrong. FIX!!!!

Specified by:

prepare in interface RetryingCallable<MultiResponse>

Overrides:

prepare in class CancellableRegionServerCallable<MultiResponse>

Parameters:

reload - Set this to true if need to requery locations

Throws:

IOException - e

getServerName

ServerName getServerName()