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, org.apache.hadoop.hbase.client.MultiResponse resp)
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,
                           org.apache.hadoop.hbase.client.MultiResponse resp)

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