public class AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T> extends AsyncRpcRetryingCallerFactory.BuilderBase
| Modifier and Type | Field and Description |
|---|---|
private AsyncMasterRequestRpcRetryingCaller.Callable<T> |
callable |
private long |
operationTimeoutNs |
private int |
priority |
private long |
rpcTimeoutNs |
maxAttempts, pauseForCQTBENs, pauseNs, startLogErrorsCnt| Constructor and Description |
|---|
MasterRequestCallerBuilder() |
private AsyncMasterRequestRpcRetryingCaller.Callable<T> callable
private long operationTimeoutNs
private long rpcTimeoutNs
private int priority
public MasterRequestCallerBuilder()
public AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T> action(AsyncMasterRequestRpcRetryingCaller.Callable<T> callable)
public AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T> operationTimeout(long operationTimeout, TimeUnit unit)
public AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T> rpcTimeout(long rpcTimeout, TimeUnit unit)
public AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T> pause(long pause, TimeUnit unit)
public AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T> pauseForCQTBE(long pause, TimeUnit unit)
public AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T> maxAttempts(int maxAttempts)
public AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T> startLogErrorsCnt(int startLogErrorsCnt)
public AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T> priority(TableName tableName)
public AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T> priority(int priority)
private void preCheck()
public AsyncMasterRequestRpcRetryingCaller<T> build()
public CompletableFuture<T> call()
build().call()Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.