Package org.apache.hadoop.hbase.client
Class AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T>
java.lang.Object
org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.BuilderBase
org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T>
- Enclosing class:
- AsyncRpcRetryingCallerFactory
public class AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T>
extends AsyncRpcRetryingCallerFactory.BuilderBase
-
Field Summary
Modifier and TypeFieldDescriptionprivate long
private int
private long
Fields inherited from class org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.BuilderBase
maxAttempts, pauseNs, pauseNsForServerOverloaded, startLogErrorsCnt
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionaction
(AsyncMasterRequestRpcRetryingCaller.Callable<T> callable) build()
call()
Shortcut forbuild().call()
maxAttempts
(int maxAttempts) operationTimeout
(long operationTimeout, TimeUnit unit) pauseForServerOverloaded
(long pause, TimeUnit unit) private void
preCheck()
priority
(int priority) rpcTimeout
(long rpcTimeout, TimeUnit unit) startLogErrorsCnt
(int startLogErrorsCnt)
-
Field Details
-
callable
-
operationTimeoutNs
-
rpcTimeoutNs
-
priority
-
-
Constructor Details
-
MasterRequestCallerBuilder
public MasterRequestCallerBuilder()
-
-
Method Details
-
action
-
operationTimeout
public AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T> operationTimeout(long operationTimeout, TimeUnit unit) -
rpcTimeout
public AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T> rpcTimeout(long rpcTimeout, TimeUnit unit) -
pause
-
pauseForServerOverloaded
public AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T> pauseForServerOverloaded(long pause, TimeUnit unit) -
maxAttempts
-
startLogErrorsCnt
public AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T> startLogErrorsCnt(int startLogErrorsCnt) -
priority
-
priority
-
preCheck
-
build
-
call
Shortcut forbuild().call()
-