Package org.apache.hadoop.hbase.client

Class AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>

java.lang.Object

org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.BuilderBase

org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>

Enclosing class:

AsyncRpcRetryingCallerFactory

public class AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>
extends AsyncRpcRetryingCallerFactory.BuilderBase

Field Summary

Fields

Modifier and Type	Field	Description
private AsyncSingleRequestRpcRetryingCaller.Callable<T>	callable
private RegionLocateType	locateType
private long	operationTimeoutNs
private int	priority
private int	replicaId
private Map<String,byte[]>	requestAttributes
private byte[]	row
private long	rpcTimeoutNs
private TableName	tableName

Fields inherited from class org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.BuilderBase

maxAttempts, pauseNs, pauseNsForServerOverloaded, startLogErrorsCnt

Constructor Summary

Constructors

Constructor	Description
SingleRequestCallerBuilder()

Method Summary

Modifier and Type	Method	Description
AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>	action(AsyncSingleRequestRpcRetryingCaller.Callable<T> callable)
AsyncSingleRequestRpcRetryingCaller<T>	build()
CompletableFuture<T>	call()	Shortcut for build().call()
AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>	locateType(RegionLocateType locateType)
AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>	maxAttempts(int maxAttempts)
AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>	operationTimeout(long operationTimeout, TimeUnit unit)
AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>	pause(long pause, TimeUnit unit)
AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>	pauseForServerOverloaded(long pause, TimeUnit unit)
private void	preCheck()
AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>	priority(int priority)
AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>	replicaId(int replicaId)
AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>	row(byte[] row)
AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>	rpcTimeout(long rpcTimeout, TimeUnit unit)
AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>	setRequestAttributes(Map<String,byte[]> requestAttributes)
AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>	startLogErrorsCnt(int startLogErrorsCnt)
AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>	table(TableName tableName)

Methods inherited from class java.lang.Object

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

Field Details

tableName

private TableName tableName

row

private byte[] row

callable

private AsyncSingleRequestRpcRetryingCaller.Callable<T> callable

operationTimeoutNs

private long operationTimeoutNs

rpcTimeoutNs

private long rpcTimeoutNs

locateType

private RegionLocateType locateType

replicaId

private int replicaId

priority

private int priority

requestAttributes

private Map<String,byte[]> requestAttributes

Constructor Details

SingleRequestCallerBuilder

public SingleRequestCallerBuilder()

Method Details

table

public AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T> table(TableName tableName)

row

public AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T> row(byte[] row)

action

public AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T> action(AsyncSingleRequestRpcRetryingCaller.Callable<T> callable)

operationTimeout

public AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T> operationTimeout(long operationTimeout,
 TimeUnit unit)

rpcTimeout

public AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T> rpcTimeout(long rpcTimeout,
 TimeUnit unit)

locateType

public AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T> locateType(RegionLocateType locateType)

pause

public AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T> pause(long pause,
 TimeUnit unit)

pauseForServerOverloaded

public AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T> pauseForServerOverloaded(long pause,
 TimeUnit unit)

maxAttempts

public AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T> maxAttempts(int maxAttempts)

startLogErrorsCnt

public AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T> startLogErrorsCnt(int startLogErrorsCnt)

replicaId

public AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T> replicaId(int replicaId)

priority

public AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T> priority(int priority)

setRequestAttributes

public AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T> setRequestAttributes(Map<String,byte[]> requestAttributes)

preCheck

private void preCheck()

build

public AsyncSingleRequestRpcRetryingCaller<T> build()

call

public CompletableFuture<T> call()

Shortcut for build().call()