Package 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	Description
private List<? extends Row>	actions
private long	operationTimeoutNs
private Map<String,byte[]>	requestAttributes
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	Description
BatchCallerBuilder()

Method Summary

Modifier and Type	Method	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	pauseForServerOverloaded(long pause, TimeUnit unit)
AsyncRpcRetryingCallerFactory.BatchCallerBuilder	rpcTimeout(long rpcTimeout, TimeUnit unit)
AsyncRpcRetryingCallerFactory.BatchCallerBuilder	setRequestAttributes(Map<String,byte[]> requestAttributes)
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 Details

tableName

private TableName tableName

actions

private List<? extends Row> actions

operationTimeoutNs

private long operationTimeoutNs

rpcTimeoutNs

private long rpcTimeoutNs

requestAttributes

private Map<String,byte[]> requestAttributes

Constructor Details

BatchCallerBuilder

public BatchCallerBuilder()

Method Details

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)

pauseForServerOverloaded

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

maxAttempts

public AsyncRpcRetryingCallerFactory.BatchCallerBuilder maxAttempts(int maxAttempts)

startLogErrorsCnt

public AsyncRpcRetryingCallerFactory.BatchCallerBuilder startLogErrorsCnt(int startLogErrorsCnt)

setRequestAttributes

public AsyncRpcRetryingCallerFactory.BatchCallerBuilder setRequestAttributes(Map<String,byte[]> requestAttributes)

build

public <T> AsyncBatchRpcRetryingCaller<T> build()

call

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