Package org.apache.hadoop.hbase.client

Class AsyncRegionReplicationRetryingCaller

java.lang.Object

org.apache.hadoop.hbase.client.AsyncRpcRetryingCaller<Void>

org.apache.hadoop.hbase.client.AsyncRegionReplicationRetryingCaller

@Private
public class AsyncRegionReplicationRetryingCaller
extends AsyncRpcRetryingCaller<Void>

For replicating edits to secondary replicas.

Field Summary

Fields

Modifier and Type	Field	Description
private final WAL.Entry[]	entries
private final RegionInfo	replica
private boolean	useReplay

Fields inherited from class org.apache.hadoop.hbase.client.AsyncRpcRetryingCaller

conn, controller, future, operationTimeoutNs

Constructor Summary

Constructors

Constructor	Description
AsyncRegionReplicationRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer retryTimer, AsyncClusterConnectionImpl conn, int maxAttempts, long rpcTimeoutNs, long operationTimeoutNs, RegionInfo replica, List<WAL.Entry> entries)

Method Summary

Modifier and Type	Method	Description
private void	call(HRegionLocation loc)
protected void	doCall()
private void	onComplete(HRegionLocation loc)
protected Throwable	preProcessError(Throwable error)

Methods inherited from class org.apache.hadoop.hbase.client.AsyncRpcRetryingCaller

call, completeExceptionally, getTableName, onError, remainingTimeNs, resetCallTimeout

Methods inherited from class java.lang.Object

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

Field Details

replica

private final RegionInfo replica

entries

private final WAL.Entry[] entries

useReplay

private boolean useReplay

Constructor Details

AsyncRegionReplicationRetryingCaller

public AsyncRegionReplicationRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer retryTimer,
 AsyncClusterConnectionImpl conn,
 int maxAttempts,
 long rpcTimeoutNs,
 long operationTimeoutNs,
 RegionInfo replica,
 List<WAL.Entry> entries)

Method Details

preProcessError

protected Throwable preProcessError(Throwable error)

Overrides:

preProcessError in class AsyncRpcRetryingCaller<Void>

onComplete

private void onComplete(HRegionLocation loc)

call

private void call(HRegionLocation loc)

doCall

protected void doCall()

Specified by:

doCall in class AsyncRpcRetryingCaller<Void>