Package org.apache.hadoop.hbase.client

Class AsyncSingleRequestRpcRetryingCaller<T>

java.lang.Object

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

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

@Private
class AsyncSingleRequestRpcRetryingCaller<T>
extends AsyncRpcRetryingCaller<T>

Retry caller for a single request, such as get, put, delete, etc.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	AsyncSingleRequestRpcRetryingCaller.Callable<T>

Field Summary

Fields

Modifier and Type	Field	Description
private final AsyncSingleRequestRpcRetryingCaller.Callable<T>	callable
private final RegionLocateType	locateType
private final int	replicaId
private final byte[]	row
private final TableName	tableName

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

conn, controller, future, operationTimeoutNs

Constructor Summary

Constructors

Constructor

Description

AsyncSingleRequestRpcRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, AsyncConnectionImpl conn, TableName tableName, byte[] row, int replicaId, RegionLocateType locateType, AsyncSingleRequestRpcRetryingCaller.Callable<T> callable, int priority, long pauseNs, long pauseNsForServerOverloaded, int maxAttempts, long operationTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt, Map<String,byte[]> requestAttributes)

Method Summary

Modifier and Type	Method	Description
private void	call(HRegionLocation loc)
protected void	doCall()
protected Optional<TableName>	getTableName()

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

call, completeExceptionally, onError, remainingTimeNs, resetCallTimeout

Methods inherited from class java.lang.Object

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

Field Details

tableName

private final TableName tableName

row

private final byte[] row

replicaId

private final int replicaId

locateType

private final RegionLocateType locateType

callable

private final AsyncSingleRequestRpcRetryingCaller.Callable<T> callable

Constructor Details

AsyncSingleRequestRpcRetryingCaller

public AsyncSingleRequestRpcRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer,
 AsyncConnectionImpl conn,
 TableName tableName,
 byte[] row,
 int replicaId,
 RegionLocateType locateType,
 AsyncSingleRequestRpcRetryingCaller.Callable<T> callable,
 int priority,
 long pauseNs,
 long pauseNsForServerOverloaded,
 int maxAttempts,
 long operationTimeoutNs,
 long rpcTimeoutNs,
 int startLogErrorsCnt,
 Map<String,byte[]> requestAttributes)

Method Details

call

private void call(HRegionLocation loc)

doCall

protected void doCall()

Specified by:

doCall in class AsyncRpcRetryingCaller<T>

getTableName

protected Optional<TableName> getTableName()

Overrides:

getTableName in class AsyncRpcRetryingCaller<T>