org.apache.hadoop.hbase.client

Class AsyncRpcRetryingCallerFactory

java.lang.Object

org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory

@InterfaceAudience.Private
class AsyncRpcRetryingCallerFactory
extends Object

Factory to create an AsyncRpcRetryCaller.

Since:

2.0.0

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder<T>
class	AsyncRpcRetryingCallerFactory.BatchCallerBuilder
private class	AsyncRpcRetryingCallerFactory.BuilderBase
class	AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T>
class	AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder
class	AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<T>
class	AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>

Field Summary

Fields

Modifier and Type	Field and Description
private AsyncConnectionImpl	conn
private org.apache.hbase.thirdparty.io.netty.util.Timer	retryTimer

Constructor Summary

Constructors

Constructor and Description
AsyncRpcRetryingCallerFactory(AsyncConnectionImpl conn, org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer)

Method Summary

Modifier and Type	Method and Description
<T> AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder<T>	adminRequest()
AsyncRpcRetryingCallerFactory.BatchCallerBuilder	batch()
<T> AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T>	masterRequest()
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder	scanSingleRegion() Create retry caller for scanning a region.
<T> AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<T>	serverRequest()
<T> AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T>	single() Create retry caller for single action, such as get, put, delete, etc.

Methods inherited from class java.lang.Object

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

Field Detail

conn

private final AsyncConnectionImpl conn

retryTimer

private final org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer

Constructor Detail

AsyncRpcRetryingCallerFactory

public AsyncRpcRetryingCallerFactory(AsyncConnectionImpl conn,
                                     org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer)

Method Detail

single

public <T> AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder<T> single()

Create retry caller for single action, such as get, put, delete, etc.

scanSingleRegion

public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder scanSingleRegion()

Create retry caller for scanning a region.

batch

public AsyncRpcRetryingCallerFactory.BatchCallerBuilder batch()

masterRequest

public <T> AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T> masterRequest()

adminRequest

public <T> AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder<T> adminRequest()

serverRequest

public <T> AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<T> serverRequest()