org.apache.hadoop.hbase.client

Class TestAsyncProcessWithRegionException.MyAsyncProcess

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncProcessWithRegionException.MyAsyncProcess

Enclosing class:

TestAsyncProcessWithRegionException

private static class TestAsyncProcessWithRegionException.MyAsyncProcess
extends Object

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
static int	DEFAULT_START_LOG_ERRORS_AFTER_COUNT
(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
(package private) org.apache.hadoop.hbase.client.RequestController	requestController
(package private) org.apache.hadoop.hbase.ipc.RpcControllerFactory	rpcFactory
(package private) long	serverTrackerTimeout
private ExecutorService	service
static String	START_LOG_ERRORS_AFTER_COUNT_KEY
(package private) int	startLogErrorsCnt

Constructor Summary

Constructors

Constructor and Description
MyAsyncProcess(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)
(package private) <CResult> org.apache.hadoop.hbase.client.AsyncRequestFutureImpl<CResult>	createAsyncRequestFuture(org.apache.hadoop.hbase.client.AsyncProcessTask arg0, List<org.apache.hadoop.hbase.client.Action> arg1, long arg2)
protected org.apache.hadoop.hbase.client.RpcRetryingCaller<org.apache.hadoop.hbase.client.AbstractResponse>	createCaller(org.apache.hadoop.hbase.client.CancellableRegionServerCallable callable, 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)
(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)
<CResult> org.apache.hadoop.hbase.client.AsyncRequestFuture	submit(org.apache.hadoop.hbase.client.AsyncProcessTask<CResult> arg0)
org.apache.hadoop.hbase.client.AsyncRequestFuture	submit(org.apache.hadoop.hbase.TableName tableName, List<? extends org.apache.hadoop.hbase.client.Row> rows)
(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 java.lang.Object

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

Field Detail

service

private final ExecutorService service

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

MyAsyncProcess

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

Method Detail

submit

public org.apache.hadoop.hbase.client.AsyncRequestFuture submit(org.apache.hadoop.hbase.TableName tableName,
                                                                List<? extends org.apache.hadoop.hbase.client.Row> rows)
                                                         throws InterruptedIOException

Throws:

InterruptedIOException

createCaller

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

submit

public <CResult> org.apache.hadoop.hbase.client.AsyncRequestFuture submit(org.apache.hadoop.hbase.client.AsyncProcessTask<CResult> arg0)
                                                                   throws InterruptedIOException

Throws:

InterruptedIOException

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)

createAsyncRequestFuture

<CResult> org.apache.hadoop.hbase.client.AsyncRequestFutureImpl<CResult> createAsyncRequestFuture(org.apache.hadoop.hbase.client.AsyncProcessTask arg0,
                                                                                                  List<org.apache.hadoop.hbase.client.Action> arg1,
                                                                                                  long arg2)

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)