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

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

allReqs, callsCt, nbActions, nbMultiResponse, service

Constructor Summary

Constructors

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

Method Summary

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

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 Detail

MyAsyncProcessWithReplicas

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

Method Detail

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