Package org.apache.hadoop.hbase.client

Class AsyncRpcRetryingCallerFactory

java.lang.Object

org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory

@Private
class AsyncRpcRetryingCallerFactory
extends Object

Factory to create an AsyncRpcRetryCaller.

Since:

2.0.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	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	Description
private final AsyncConnectionImpl	conn
private final org.apache.hbase.thirdparty.io.netty.util.Timer	retryTimer

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

conn

private final AsyncConnectionImpl conn

retryTimer

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

Constructor Details

AsyncRpcRetryingCallerFactory

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

Method Details

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()