org.apache.hadoop.hbase.client

Class TestAsyncProcess.MyAsyncRequestFutureImpl<Res>

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncProcess.MyAsyncRequestFutureImpl<Res>

All Implemented Interfaces:

org.apache.hadoop.hbase.client.AsyncRequestFuture

Enclosing class:

TestAsyncProcess

static class TestAsyncProcess.MyAsyncRequestFutureImpl<Res>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	org.apache.hadoop.hbase.client.AsyncRequestFutureImpl.Retry
(package private) class	org.apache.hadoop.hbase.client.AsyncRequestFutureImpl.SingleServerRequestRunnable

Field Summary

Fields

Modifier and Type	Field and Description
private Map<org.apache.hadoop.hbase.ServerName,List<Long>>	heapSizesByServer

Constructor Summary

Constructors

Constructor and Description
MyAsyncRequestFutureImpl(org.apache.hadoop.hbase.client.AsyncProcessTask task, List<org.apache.hadoop.hbase.client.Action> actions, long nonceGroup, org.apache.hadoop.hbase.client.AsyncProcess asyncProcess)

Method Summary

Modifier and Type	Method and Description
(package private) org.apache.hadoop.hbase.client.AsyncRequestFutureImpl.SingleServerRequestRunnable	createSingleServerRequest(org.apache.hadoop.hbase.client.MultiAction multiAction, int numAttempt, org.apache.hadoop.hbase.ServerName server, Set<org.apache.hadoop.hbase.client.CancellableRegionServerCallable> callsInProgress)
protected Set<org.apache.hadoop.hbase.client.CancellableRegionServerCallable>	getCallsInProgress()
org.apache.hadoop.hbase.client.RetriesExhaustedWithDetailsException	getErrors()
List<? extends org.apache.hadoop.hbase.client.Row>	getFailedOperations()
(package private) long	getNumberOfActionsInProgress()
(package private) Map<org.apache.hadoop.hbase.ServerName,List<Long>>	getRequestHeapSize()
Object[]	getResults()
(package private) void	groupAndSendMultiAction(List<org.apache.hadoop.hbase.client.Action> arg0, int arg1)
boolean	hasError()
private long	heapSizeOf(org.apache.hadoop.hbase.client.MultiAction multiAction)
(package private) org.apache.hadoop.hbase.client.AsyncRequestFutureImpl.Retry	manageError(int arg0, org.apache.hadoop.hbase.client.Row arg1, org.apache.hadoop.hbase.client.AsyncRequestFutureImpl.Retry arg2, Throwable arg3, org.apache.hadoop.hbase.ServerName arg4)
(package private) void	sendMultiAction(Map<org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.client.MultiAction> arg0, int arg1, List<org.apache.hadoop.hbase.client.Action> arg2, boolean arg3)
protected void	updateStats(org.apache.hadoop.hbase.ServerName server, Map<byte[],org.apache.hadoop.hbase.client.MultiResponse.RegionResult> results)
void	waitUntilDone()

Methods inherited from class java.lang.Object

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

Field Detail

heapSizesByServer

private final Map<org.apache.hadoop.hbase.ServerName,List<Long>> heapSizesByServer

Constructor Detail

MyAsyncRequestFutureImpl

public MyAsyncRequestFutureImpl(org.apache.hadoop.hbase.client.AsyncProcessTask task,
                                List<org.apache.hadoop.hbase.client.Action> actions,
                                long nonceGroup,
                                org.apache.hadoop.hbase.client.AsyncProcess asyncProcess)

Method Detail

updateStats

protected void updateStats(org.apache.hadoop.hbase.ServerName server,
                           Map<byte[],org.apache.hadoop.hbase.client.MultiResponse.RegionResult> results)

getRequestHeapSize

Map<org.apache.hadoop.hbase.ServerName,List<Long>> getRequestHeapSize()

createSingleServerRequest

org.apache.hadoop.hbase.client.AsyncRequestFutureImpl.SingleServerRequestRunnable createSingleServerRequest(org.apache.hadoop.hbase.client.MultiAction multiAction,
                                                                                                            int numAttempt,
                                                                                                            org.apache.hadoop.hbase.ServerName server,
                                                                                                            Set<org.apache.hadoop.hbase.client.CancellableRegionServerCallable> callsInProgress)

heapSizeOf

private long heapSizeOf(org.apache.hadoop.hbase.client.MultiAction multiAction)

getCallsInProgress

protected Set<org.apache.hadoop.hbase.client.CancellableRegionServerCallable> getCallsInProgress()

groupAndSendMultiAction

void groupAndSendMultiAction(List<org.apache.hadoop.hbase.client.Action> arg0,
                             int arg1)

sendMultiAction

void sendMultiAction(Map<org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.client.MultiAction> arg0,
                     int arg1,
                     List<org.apache.hadoop.hbase.client.Action> arg2,
                     boolean arg3)

manageError

org.apache.hadoop.hbase.client.AsyncRequestFutureImpl.Retry manageError(int arg0,
                                                                        org.apache.hadoop.hbase.client.Row arg1,
                                                                        org.apache.hadoop.hbase.client.AsyncRequestFutureImpl.Retry arg2,
                                                                        Throwable arg3,
                                                                        org.apache.hadoop.hbase.ServerName arg4)

waitUntilDone

public void waitUntilDone()
                   throws InterruptedIOException

Specified by:

waitUntilDone in interface org.apache.hadoop.hbase.client.AsyncRequestFuture

Throws:

InterruptedIOException

hasError

public boolean hasError()

Specified by:

hasError in interface org.apache.hadoop.hbase.client.AsyncRequestFuture

getFailedOperations

public List<? extends org.apache.hadoop.hbase.client.Row> getFailedOperations()

Specified by:

getFailedOperations in interface org.apache.hadoop.hbase.client.AsyncRequestFuture

getErrors

public org.apache.hadoop.hbase.client.RetriesExhaustedWithDetailsException getErrors()

Specified by:

getErrors in interface org.apache.hadoop.hbase.client.AsyncRequestFuture

getResults

public Object[] getResults()
                    throws InterruptedIOException

Specified by:

getResults in interface org.apache.hadoop.hbase.client.AsyncRequestFuture

Throws:

InterruptedIOException

getNumberOfActionsInProgress

long getNumberOfActionsInProgress()