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

Constructor Summary

Constructors

Constructor	Description
MyAsyncProcess(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)
(package private) <CResult extends Object> 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 extends Object> 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 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 java.lang.Object

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

Field Details

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 Details

MyAsyncProcess

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

Method Details

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 extends Object>
org.apache.hadoop.hbase.client.AsyncRequestFuture submit(org.apache.hadoop.hbase.client.AsyncProcessTask<CResult> arg0)
                                                  throws InterruptedIOException

Throws:

InterruptedIOException

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)

createAsyncRequestFuture

<CResult extends Object>
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)