org.apache.hadoop.hbase.client

Class RegionServerCallable<T>

java.lang.Object

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

Type Parameters:

T - the class that the ServerCallable handles

All Implemented Interfaces:

RetryingCallable<T>

Direct Known Subclasses:

ScannerCallable

@InterfaceAudience.Private
public abstract class RegionServerCallable<T>
extends Object
implements RetryingCallable<T>

Implementations call a RegionServer and implement RetryingCallable.call(int). Passed to a RpcRetryingCaller so we retry on fail. TODO: this class is actually tied to one region, because most of the paths make use of the regioninfo part of location when building requests. The only reason it works for multi-region requests (e.g. batch) is that they happen to not use the region parts. This could be done cleaner (e.g. having a generic parameter and 2 derived classes, RegionCallable and actual RegionServerCallable with ServerName.

Field Summary

Fields

Modifier and Type	Field and Description
protected Connection	connection
protected HRegionLocation	location
protected static int	MIN_WAIT_DEAD_SERVER
protected byte[]	row
protected TableName	tableName

Constructor Summary

Constructors

Constructor and Description
RegionServerCallable(Connection connection, TableName tableName, byte[] row)

Method Summary

Methods

Modifier and Type	Method and Description
String	getExceptionMessageAdditionalDetail()
HRegionInfo	getHRegionInfo()
protected HRegionLocation	getLocation()
byte[]	getRow()
protected ClientProtos.ClientService.BlockingInterface	getStub()
TableName	getTableName()
void	prepare(boolean reload) Prepare for connection to the server hosting region with row from tablename.
protected void	setLocation(HRegionLocation location)
long	sleep(long pause, int tries)
void	throwable(Throwable t, boolean retrying) Called when RetryingCallable.call(int) throws an exception and we are going to retry; take action to make it so we succeed on next call (clear caches, do relookup of locations, etc.).

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.client.RetryingCallable

call

Field Detail

connection

protected final Connection connection

tableName

protected final TableName tableName

row

protected final byte[] row

location

protected HRegionLocation location

MIN_WAIT_DEAD_SERVER

protected static final int MIN_WAIT_DEAD_SERVER

See Also:

Constant Field Values

Constructor Detail

RegionServerCallable

public RegionServerCallable(Connection connection,
                    TableName tableName,
                    byte[] row)

Parameters:

connection - Connection to use.

tableName - Table name to which row belongs.

row - The row we want in tableName.

Method Detail

prepare

public void prepare(boolean reload)
             throws IOException

Prepare for connection to the server hosting region with row from tablename. Does lookup to find region location and hosting server.

Specified by:

prepare in interface RetryingCallable<T>

Parameters:

reload - Set this to true if connection should re-find the region

Throws:

IOException - e

getStub

protected ClientProtos.ClientService.BlockingInterface getStub()

getLocation

protected HRegionLocation getLocation()

setLocation

protected void setLocation(HRegionLocation location)

getTableName

public TableName getTableName()

getRow

public byte[] getRow()

throwable

public void throwable(Throwable t,
             boolean retrying)

Description copied from interface: RetryingCallable

Called when RetryingCallable.call(int) throws an exception and we are going to retry; take action to make it so we succeed on next call (clear caches, do relookup of locations, etc.).

Specified by:

throwable in interface RetryingCallable<T>

retrying - True if we are in retrying mode (we are not in retrying mode when max retries == 1; we ARE in retrying mode if retries > 1 even when we are the last attempt)

getExceptionMessageAdditionalDetail

public String getExceptionMessageAdditionalDetail()

Specified by:

getExceptionMessageAdditionalDetail in interface RetryingCallable<T>

Returns:

Some details from the implementation that we would like to add to a terminating exception; i.e. a fatal exception is being thrown ending retries and we might like to add more implementation-specific detail on to the exception being thrown.

sleep

public long sleep(long pause,
         int tries)

Specified by:

sleep in interface RetryingCallable<T>

Returns:

Suggestion on how much to sleep between retries

getHRegionInfo

public HRegionInfo getHRegionInfo()

Returns:

the HRegionInfo for the current region