Package org.apache.hadoop.hbase.client

Class ClientServiceCallable<T>

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>

All Implemented Interfaces:

RetryingCallable<T>

Direct Known Subclasses:

CancellableRegionServerCallable, NoncedRegionServerCallable, ScannerCallable

@Private
public abstract class ClientServiceCallable<T>
extends RegionServerCallable<T,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface>

A RegionServerCallable set to use the Client protocol. Also includes some utility methods so can hide protobuf references here rather than have them sprinkled about the code base.

Field Summary

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

location, requestAttributes, rpcController, stub

Constructor Summary

Constructors

Constructor	Description
ClientServiceCallable(Connection connection, TableName tableName, byte[] row, org.apache.hbase.thirdparty.com.google.protobuf.RpcController rpcController, int priority, Map<String,byte[]> requestAttributes)

Method Summary

Modifier and Type	Method	Description
protected org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.GetResponse	doGet(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.GetRequest request)
protected org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateResponse	doMutate(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateRequest request)
protected void	setStubByServiceName(ServerName serviceName)	Set the RCP client stub

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

call, getConnection, getExceptionMessageAdditionalDetail, getHRegionInfo, getLocation, getPriority, getRow, getRpcController, getRpcControllerCellScanner, getStub, getTableName, prepare, rpcCall, setLocation, setRpcControllerCellScanner, setStub, sleep, throwable

Methods inherited from class java.lang.Object

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

Constructor Details

ClientServiceCallable

public ClientServiceCallable(Connection connection,
 TableName tableName,
 byte[] row,
 org.apache.hbase.thirdparty.com.google.protobuf.RpcController rpcController,
 int priority,
 Map<String,byte[]> requestAttributes)

Method Details

setStubByServiceName

protected void setStubByServiceName(ServerName serviceName)
                             throws IOException

Description copied from class: RegionServerCallable

Set the RCP client stub

Specified by:

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

Parameters:

serviceName - to get the rpc stub for

Throws:

IOException - When client could not be created

doGet

protected org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.GetResponse doGet(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.GetRequest request)
                                                                                    throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

doMutate

protected org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateResponse doMutate(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateRequest request)
                                                                                          throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException