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 and Description
private AsyncSingleRequestRpcRetryingCaller.Callable<T>	callable
private RegionLocateType	locateType
private long	operationTimeoutNs
private int	priority
private int	replicaId
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 and Description
SingleRequestCallerBuilder()

Method Summary

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

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

Constructor Detail

SingleRequestCallerBuilder

public SingleRequestCallerBuilder()

Method Detail

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)

preCheck

private void preCheck()

build

public AsyncSingleRequestRpcRetryingCaller<T> build()

call

public CompletableFuture<T> call()

Shortcut for build().call()