org.apache.hadoop.hbase.client

Class AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<T>

java.lang.Object

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

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

Enclosing class:

AsyncRpcRetryingCallerFactory

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

Field Summary

Fields

Modifier and Type	Field and Description
private AsyncServerRequestRpcRetryingCaller.Callable<T>	callable
private long	operationTimeoutNs
private long	rpcTimeoutNs
private ServerName	serverName

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

maxAttempts, pauseForCQTBENs, pauseNs, startLogErrorsCnt

Constructor Summary

Constructors

Constructor and Description
ServerRequestCallerBuilder()

Method Summary

Modifier and Type	Method and Description
AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<T>	action(AsyncServerRequestRpcRetryingCaller.Callable<T> callable)
AsyncServerRequestRpcRetryingCaller<T>	build()
CompletableFuture<T>	call()
AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<T>	maxAttempts(int maxAttempts)
AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<T>	operationTimeout(long operationTimeout, TimeUnit unit)
AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<T>	pause(long pause, TimeUnit unit)
AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<T>	pauseForCQTBE(long pause, TimeUnit unit)
AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<T>	rpcTimeout(long rpcTimeout, TimeUnit unit)
AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<T>	serverName(ServerName serverName)
AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<T>	startLogErrorsCnt(int startLogErrorsCnt)

Methods inherited from class java.lang.Object

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

Field Detail

callable

private AsyncServerRequestRpcRetryingCaller.Callable<T> callable

operationTimeoutNs

private long operationTimeoutNs

rpcTimeoutNs

private long rpcTimeoutNs

serverName

private ServerName serverName

Constructor Detail

ServerRequestCallerBuilder

public ServerRequestCallerBuilder()

Method Detail

action

public AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<T> action(AsyncServerRequestRpcRetryingCaller.Callable<T> callable)

operationTimeout

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

rpcTimeout

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

pause

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

pauseForCQTBE

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

maxAttempts

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

startLogErrorsCnt

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

serverName

public AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<T> serverName(ServerName serverName)

build

public AsyncServerRequestRpcRetryingCaller<T> build()

call

public CompletableFuture<T> call()