Package 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
    Description
    static enum 
    org.apache.hadoop.hbase.client.AsyncRequestFutureImpl.Retry
     
    (package private) final class 
    org.apache.hadoop.hbase.client.AsyncRequestFutureImpl.SingleServerRequestRunnable
     

  • Field Summary

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

  • Constructor Summary

    Constructors
    Constructor
    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
    Description
    (package private) org.apache.hadoop.hbase.client.AsyncRequestFutureImpl<Res>.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 Details

  • Constructor Details

    • 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 Details

    • 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<Res>.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()