org.apache.hadoop.hbase.client

Class AsyncRpcRetryingCallerFactory.BatchCallerBuilder

java.lang.Object

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

org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.BatchCallerBuilder

Enclosing class:

AsyncRpcRetryingCallerFactory

public class AsyncRpcRetryingCallerFactory.BatchCallerBuilder
extends AsyncRpcRetryingCallerFactory.BuilderBase

Field Summary

Fields

Modifier and Type	Field and Description
private List<? extends Row>	actions
private long	operationTimeoutNs
private long	rpcTimeoutNs
private TableName	tableName

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

maxAttempts, pauseNs, startLogErrorsCnt

Constructor Summary

Constructors

Constructor and Description
BatchCallerBuilder()

Method Summary

Modifier and Type	Method and Description
AsyncRpcRetryingCallerFactory.BatchCallerBuilder	actions(List<? extends Row> actions)
<T> AsyncBatchRpcRetryingCaller<T>	build()
<T> List<CompletableFuture<T>>	call()
AsyncRpcRetryingCallerFactory.BatchCallerBuilder	maxAttempts(int maxAttempts)
AsyncRpcRetryingCallerFactory.BatchCallerBuilder	operationTimeout(long operationTimeout, TimeUnit unit)
AsyncRpcRetryingCallerFactory.BatchCallerBuilder	pause(long pause, TimeUnit unit)
AsyncRpcRetryingCallerFactory.BatchCallerBuilder	rpcTimeout(long rpcTimeout, TimeUnit unit)
AsyncRpcRetryingCallerFactory.BatchCallerBuilder	startLogErrorsCnt(int startLogErrorsCnt)
AsyncRpcRetryingCallerFactory.BatchCallerBuilder	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

actions

private List<? extends Row> actions

operationTimeoutNs

private long operationTimeoutNs

rpcTimeoutNs

private long rpcTimeoutNs

Constructor Detail

BatchCallerBuilder

public BatchCallerBuilder()

Method Detail

table

public AsyncRpcRetryingCallerFactory.BatchCallerBuilder table(TableName tableName)

actions

public AsyncRpcRetryingCallerFactory.BatchCallerBuilder actions(List<? extends Row> actions)

operationTimeout

public AsyncRpcRetryingCallerFactory.BatchCallerBuilder operationTimeout(long operationTimeout,
                                                                         TimeUnit unit)

rpcTimeout

public AsyncRpcRetryingCallerFactory.BatchCallerBuilder rpcTimeout(long rpcTimeout,
                                                                   TimeUnit unit)

pause

public AsyncRpcRetryingCallerFactory.BatchCallerBuilder pause(long pause,
                                                              TimeUnit unit)

maxAttempts

public AsyncRpcRetryingCallerFactory.BatchCallerBuilder maxAttempts(int maxAttempts)

startLogErrorsCnt

public AsyncRpcRetryingCallerFactory.BatchCallerBuilder startLogErrorsCnt(int startLogErrorsCnt)

build

public <T> AsyncBatchRpcRetryingCaller<T> build()

call

public <T> List<CompletableFuture<T>> call()