Package org.apache.hadoop.hbase.client

Class TestAsyncProcess.MyAsyncProcessWithReplicas

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncProcess.MyAsyncProcess

org.apache.hadoop.hbase.client.TestAsyncProcess.MyAsyncProcessWithReplicas

Enclosing class:

TestAsyncProcess

static class TestAsyncProcess.MyAsyncProcessWithReplicas
extends TestAsyncProcess.MyAsyncProcess

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final org.apache.hadoop.hbase.client.ClusterConnection	connection
(package private) final org.apache.hadoop.hbase.client.ConnectionConfiguration	connectionConfiguration
private Map<org.apache.hadoop.hbase.ServerName,Long>	customPrimarySleepMs
static final int	DEFAULT_START_LOG_ERRORS_AFTER_COUNT
private Set<byte[]>	failures
(package private) final long	id
static final String	LOG_DETAILS_FOR_BATCH_ERROR
static final String	LOG_DETAILS_PERIOD
(package private) final boolean	logBatchErrorDetails
(package private) final int	numTries
static final String	PRIMARY_CALL_TIMEOUT_KEY
(package private) final long	primaryCallTimeoutMicroseconds
private long	primarySleepMs
private final AtomicLong	replicaCalls
private long	replicaSleepMs
(package private) final org.apache.hadoop.hbase.client.RequestController	requestController
(package private) final org.apache.hadoop.hbase.ipc.RpcControllerFactory	rpcFactory
(package private) long	serverTrackerTimeout
static final String	START_LOG_ERRORS_AFTER_COUNT_KEY
(package private) final int	startLogErrorsCnt

Fields inherited from class org.apache.hadoop.hbase.client.TestAsyncProcess.MyAsyncProcess

allReqs, callsCt, nbActions, nbMultiResponse, service

Constructor Summary

Constructors

Constructor	Description
MyAsyncProcessWithReplicas(org.apache.hadoop.hbase.client.ClusterConnection hc, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
(package private) static void	addAction(org.apache.hadoop.hbase.ServerName arg0, byte[] arg1, org.apache.hadoop.hbase.client.Action arg2, Map<org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.client.MultiAction> arg3, long arg4)
void	addFailures(org.apache.hadoop.hbase.client.RegionInfo... hris)
protected org.apache.hadoop.hbase.client.RpcRetryingCaller<org.apache.hadoop.hbase.client.AbstractResponse>	createCaller(org.apache.hadoop.hbase.client.CancellableRegionServerCallable payloadCallable, int rpcTimeout)
(package private) org.apache.hadoop.hbase.client.ConnectionImplementation.ServerErrorTracker	createServerErrorTracker()
(package private) void	decTaskCounters(Collection<byte[]> arg0, org.apache.hadoop.hbase.ServerName arg1)
long	getReplicaCallCount()
(package private) void	incTaskCounters(Collection<byte[]> arg0, org.apache.hadoop.hbase.ServerName arg1)
(package private) static boolean	isReplicaGet(org.apache.hadoop.hbase.client.Row arg0)
void	setCallDelays(long primaryMs, long replicaMs)
void	setPrimaryCallDelay(org.apache.hadoop.hbase.ServerName server, long primaryMs)
(package private) <CResult extends Object> org.apache.hadoop.hbase.client.AsyncRequestFuture	submitMultiActions(org.apache.hadoop.hbase.client.AsyncProcessTask arg0, List<org.apache.hadoop.hbase.client.Action> arg1, long arg2, List<Exception> arg3, List<Integer> arg4, Map<org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.client.MultiAction> arg5)
protected void	waitForMaximumCurrentTasks(int arg0, org.apache.hadoop.hbase.TableName arg1)

Methods inherited from class org.apache.hadoop.hbase.client.TestAsyncProcess.MyAsyncProcess

createAsyncRequestFuture, submit, submit, submit

Methods inherited from class java.lang.Object

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

Field Details

failures

private Set<byte[]> failures

primarySleepMs

private long primarySleepMs

replicaSleepMs

private long replicaSleepMs

customPrimarySleepMs

private Map<org.apache.hadoop.hbase.ServerName,Long> customPrimarySleepMs

replicaCalls

private final AtomicLong replicaCalls

PRIMARY_CALL_TIMEOUT_KEY

public static final String PRIMARY_CALL_TIMEOUT_KEY

See Also:

• Constant Field Values

START_LOG_ERRORS_AFTER_COUNT_KEY

public static final String START_LOG_ERRORS_AFTER_COUNT_KEY

See Also:

• Constant Field Values

DEFAULT_START_LOG_ERRORS_AFTER_COUNT

public static final int DEFAULT_START_LOG_ERRORS_AFTER_COUNT

See Also:

• Constant Field Values

LOG_DETAILS_FOR_BATCH_ERROR

public static final String LOG_DETAILS_FOR_BATCH_ERROR

See Also:

• Constant Field Values

id

final long id

connection

final org.apache.hadoop.hbase.client.ClusterConnection connection

connectionConfiguration

final org.apache.hadoop.hbase.client.ConnectionConfiguration connectionConfiguration

rpcFactory

final org.apache.hadoop.hbase.ipc.RpcControllerFactory rpcFactory

startLogErrorsCnt

final int startLogErrorsCnt

numTries

final int numTries

serverTrackerTimeout

long serverTrackerTimeout

primaryCallTimeoutMicroseconds

final long primaryCallTimeoutMicroseconds

logBatchErrorDetails

final boolean logBatchErrorDetails

requestController

final org.apache.hadoop.hbase.client.RequestController requestController

LOG_DETAILS_PERIOD

public static final String LOG_DETAILS_PERIOD

See Also:

• Constant Field Values

Constructor Details

MyAsyncProcessWithReplicas

public MyAsyncProcessWithReplicas(org.apache.hadoop.hbase.client.ClusterConnection hc,
 org.apache.hadoop.conf.Configuration conf)

Method Details

addFailures

public void addFailures(org.apache.hadoop.hbase.client.RegionInfo... hris)

getReplicaCallCount

public long getReplicaCallCount()

setPrimaryCallDelay

public void setPrimaryCallDelay(org.apache.hadoop.hbase.ServerName server,
 long primaryMs)

setCallDelays

public void setCallDelays(long primaryMs,
 long replicaMs)

createCaller

protected org.apache.hadoop.hbase.client.RpcRetryingCaller<org.apache.hadoop.hbase.client.AbstractResponse> createCaller(org.apache.hadoop.hbase.client.CancellableRegionServerCallable payloadCallable,
 int rpcTimeout)

Overrides:

createCaller in class TestAsyncProcess.MyAsyncProcess

submitMultiActions

<CResult extends Object>
org.apache.hadoop.hbase.client.AsyncRequestFuture submitMultiActions(org.apache.hadoop.hbase.client.AsyncProcessTask arg0,
 List<org.apache.hadoop.hbase.client.Action> arg1,
 long arg2,
 List<Exception> arg3,
 List<Integer> arg4,
 Map<org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.client.MultiAction> arg5)

addAction

static void addAction(org.apache.hadoop.hbase.ServerName arg0,
 byte[] arg1,
 org.apache.hadoop.hbase.client.Action arg2,
 Map<org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.client.MultiAction> arg3,
 long arg4)

waitForMaximumCurrentTasks

protected void waitForMaximumCurrentTasks(int arg0,
 org.apache.hadoop.hbase.TableName arg1)
                                   throws InterruptedIOException

Throws:

InterruptedIOException

incTaskCounters

void incTaskCounters(Collection<byte[]> arg0,
 org.apache.hadoop.hbase.ServerName arg1)

decTaskCounters

void decTaskCounters(Collection<byte[]> arg0,
 org.apache.hadoop.hbase.ServerName arg1)

createServerErrorTracker

org.apache.hadoop.hbase.client.ConnectionImplementation.ServerErrorTracker createServerErrorTracker()

isReplicaGet

static boolean isReplicaGet(org.apache.hadoop.hbase.client.Row arg0)