Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 41455200BA7 for ; Fri, 16 Sep 2016 03:57:08 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 3FD03160AE4; Fri, 16 Sep 2016 01:57:08 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 9C545160ADA for ; Fri, 16 Sep 2016 03:57:05 +0200 (CEST) Received: (qmail 41258 invoked by uid 500); 16 Sep 2016 01:57:02 -0000 Mailing-List: contact commits-help@hbase.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@hbase.apache.org Delivered-To: mailing list commits@hbase.apache.org Received: (qmail 40238 invoked by uid 99); 16 Sep 2016 01:57:01 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 16 Sep 2016 01:57:01 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 63D62EF793; Fri, 16 Sep 2016 01:57:01 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: dimaspivak@apache.org To: commits@hbase.apache.org Date: Fri, 16 Sep 2016 01:57:13 -0000 Message-Id: <4e9f765bda5542b4a073a4e8ac968f0a@git.apache.org> In-Reply-To: <1adfd2ce4405497b80d48473de1a7041@git.apache.org> References: <1adfd2ce4405497b80d48473de1a7041@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [13/52] [partial] hbase-site git commit: Published site at 56be3ac7c8d203710f844cd799f2fa3496f0515a. archived-at: Fri, 16 Sep 2016 01:57:08 -0000 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html index 3b44e25..a84c620 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html @@ -500,7 +500,7 @@ implements
  • callback

    -
    private final Batch.Callback<CResult> callback
    +
    private final Batch.Callback<CResult> callback
  • @@ -509,7 +509,7 @@ implements
  • errors

    -
    private final AsyncProcess.BatchErrors errors
    +
    private final AsyncProcess.BatchErrors errors
  • @@ -518,7 +518,7 @@ implements
  • errorsByServer

    -
    private final ConnectionImplementation.ServerErrorTracker errorsByServer
    +
    private final ConnectionImplementation.ServerErrorTracker errorsByServer
  • @@ -527,7 +527,7 @@ implements
  • pool

    -
    private final ExecutorService pool
    +
    private final ExecutorService pool
  • @@ -536,7 +536,7 @@ implements
  • callsInProgress

    -
    private final Set<CancellableRegionServerCallable> callsInProgress
    +
    private final Set<CancellableRegionServerCallable> callsInProgress
  • @@ -545,7 +545,7 @@ implements
  • tableName

    -
    private final TableName tableName
    +
    private final TableName tableName
  • @@ -554,7 +554,7 @@ implements
  • actionsInProgress

    -
    private final AtomicLong actionsInProgress
    +
    private final AtomicLong actionsInProgress
  • @@ -563,7 +563,7 @@ implements
  • replicaResultLock

    -
    private final Object replicaResultLock
    +
    private final Object replicaResultLock
    The lock controls access to results. It is only held when populating results where there might be several callers (eventual consistency gets). For other requests, there's one unique call going on per result index.
    @@ -575,7 +575,7 @@ implements
  • results

    -
    private final Object[] results
    +
    private final Object[] results
    Result array. Null if results are not needed. Otherwise, each index corresponds to the action index in initial actions submitted. For most request types, has null-s for requests that are not done, and result/exception for those that are done. @@ -591,7 +591,7 @@ implements
  • replicaGetIndices

    -
    private final int[] replicaGetIndices
    +
    private final int[] replicaGetIndices
    Indices of replica gets in results. If null, all or no actions are replica-gets.
  • @@ -601,7 +601,7 @@ implements
  • hasAnyReplicaGets

    -
    private final boolean hasAnyReplicaGets
    +
    private final boolean hasAnyReplicaGets
  • @@ -610,7 +610,7 @@ implements
  • nonceGroup

    -
    private final long nonceGroup
    +
    private final long nonceGroup
  • @@ -619,7 +619,7 @@ implements
  • currentCallable

    -
    private CancellableRegionServerCallable currentCallable
    +
    private CancellableRegionServerCallable currentCallable
  • @@ -628,7 +628,7 @@ implements
  • currentCallTotalTimeout

    -
    private int currentCallTotalTimeout
    +
    private int currentCallTotalTimeout
  • @@ -637,7 +637,7 @@ implements
  • heapSizesByServer

    -
    private final Map<ServerName,List<Long>> heapSizesByServer
    +
    private final Map<ServerName,List<Long>> heapSizesByServer
  • @@ -654,7 +654,7 @@ implements
  • AsyncRequestFutureImpl

    -
    public AsyncRequestFutureImpl(TableName tableName,
    +
    public AsyncRequestFutureImpl(TableName tableName,
                                   List<Action<Row>> actions,
                                   long nonceGroup,
                                   ExecutorService pool,
    @@ -679,7 +679,7 @@ implements 
     
  • getCallsInProgress

    -
    public Set<CancellableRegionServerCallablegetCallsInProgress()
    +
    public Set<CancellableRegionServerCallablegetCallsInProgress()
  • @@ -688,7 +688,7 @@ implements
  • getRequestHeapSize

    -
    Map<ServerName,List<Long>> getRequestHeapSize()
    +
    Map<ServerName,List<Long>> getRequestHeapSize()
  • @@ -697,7 +697,7 @@ implements
  • addSingleServerRequestHeapSize

    -
    private AsyncProcess.AsyncRequestFutureImpl.SingleServerRequestRunnable addSingleServerRequestHeapSize(ServerName server,
    +
    private AsyncProcess.AsyncRequestFutureImpl.SingleServerRequestRunnable addSingleServerRequestHeapSize(ServerName server,
                                                                                                            AsyncProcess.AsyncRequestFutureImpl.SingleServerRequestRunnable runnable)
  • @@ -707,7 +707,7 @@ implements
  • groupAndSendMultiAction

    -
    private void groupAndSendMultiAction(List<Action<Row>> currentActions,
    +
    private void groupAndSendMultiAction(List<Action<Row>> currentActions,
                                          int numAttempt)
    Group a list of actions per region servers, and send them.
    @@ -723,7 +723,7 @@ implements
  • getReplicaLocationOrFail

    -
    private HRegionLocation getReplicaLocationOrFail(Action<Row> action)
    +
    private HRegionLocation getReplicaLocationOrFail(Action<Row> action)
  • @@ -732,7 +732,7 @@ implements
  • manageLocationError

    -
    private void manageLocationError(Action<Row> action,
    +
    private void manageLocationError(Action<Row> action,
                                      Exception ex)
  • @@ -742,7 +742,7 @@ implements
  • findAllLocationsOrFail

    -
    private RegionLocations findAllLocationsOrFail(Action<Row> action,
    +
    private RegionLocations findAllLocationsOrFail(Action<Row> action,
                                                    boolean useCache)
  • @@ -752,7 +752,7 @@ implements
  • sendMultiAction

    -
    private void sendMultiAction(Map<ServerName,MultiAction<Row>> actionsByServer,
    +
    private void sendMultiAction(Map<ServerName,MultiAction<Row>> actionsByServer,
                                  int numAttempt,
                                  List<Action<Row>> actionsForReplicaThread,
                                  boolean reuseThread)
    @@ -772,7 +772,7 @@ implements
  • getNewMultiActionRunnable

    -
    private Collection<? extends RunnablegetNewMultiActionRunnable(ServerName server,
    +
    private Collection<? extends RunnablegetNewMultiActionRunnable(ServerName server,
                                                                      MultiAction<Row> multiAction,
                                                                      int numAttempt)
  • @@ -783,7 +783,7 @@ implements
  • getBackoff

    -
    private Long getBackoff(ServerName server,
    +
    private Long getBackoff(ServerName server,
                             byte[] regionName)
    Parameters:
    @@ -801,7 +801,7 @@ implements
  • startWaitingForReplicaCalls

    -
    private void startWaitingForReplicaCalls(List<Action<Row>> actionsForReplicaThread)
    +
    private void startWaitingForReplicaCalls(List<Action<Row>> actionsForReplicaThread)
    Starts waiting to issue replica calls on a different thread; or issues them immediately.
  • @@ -811,7 +811,7 @@ implements
  • manageError

    -
    public AsyncProcess.Retry manageError(int originalIndex,
    +
    public AsyncProcess.Retry manageError(int originalIndex,
                                           Row row,
                                           AsyncProcess.Retry canRetry,
                                           Throwable throwable,
    @@ -835,7 +835,7 @@ implements 
     
  • receiveGlobalFailure

    -
    private void receiveGlobalFailure(MultiAction<Row> rsActions,
    +
    private void receiveGlobalFailure(MultiAction<Row> rsActions,
                                       ServerName server,
                                       int numAttempt,
                                       Throwable t)
    @@ -855,7 +855,7 @@ implements
  • resubmit

    -
    private void resubmit(ServerName oldServer,
    +
    private void resubmit(ServerName oldServer,
                           List<Action<Row>> toReplay,
                           int numAttempt,
                           int failureCount,
    @@ -870,7 +870,7 @@ implements 
     
  • logNoResubmit

    -
    private void logNoResubmit(ServerName oldServer,
    +
    private void logNoResubmit(ServerName oldServer,
                                int numAttempt,
                                int failureCount,
                                Throwable throwable,
    @@ -884,7 +884,7 @@ implements 
     
  • receiveMultiAction

    -
    private void receiveMultiAction(MultiAction<Row> multiAction,
    +
    private void receiveMultiAction(MultiAction<Row> multiAction,
                                     ServerName server,
                                     MultiResponse responses,
                                     int numAttempt)
    @@ -904,7 +904,7 @@ implements
  • createLog

    -
    private String createLog(int numAttempt,
    +
    private String createLog(int numAttempt,
                              int failureCount,
                              int replaySize,
                              ServerName sn,
    @@ -922,7 +922,7 @@ implements 
     
  • setResult

    -
    private void setResult(Action<Row> action,
    +
    private void setResult(Action<Row> action,
                            Object result)
    Sets the non-error result from a particular action.
    @@ -938,7 +938,7 @@ implements
  • setError

    -
    private void setError(int index,
    +
    private void setError(int index,
                           Row row,
                           Throwable throwable,
                           ServerName server)
    @@ -958,7 +958,7 @@ implements
  • isActionComplete

    -
    private boolean isActionComplete(int index,
    +
    private boolean isActionComplete(int index,
                                      Row row)
    Checks if the action is complete; used on error to prevent needless retries. Does not synchronize, assuming element index/field accesses are atomic. @@ -976,7 +976,7 @@ implements
  • trySetResultSimple

    -
    private AsyncProcess.ReplicaResultState trySetResultSimple(int index,
    +
    private AsyncProcess.ReplicaResultState trySetResultSimple(int index,
                                                                Row row,
                                                                boolean isError,
                                                                Object result,
    @@ -995,7 +995,7 @@ implements 
     
  • decActionCounter

    -
    private void decActionCounter(int index)
    +
    private void decActionCounter(int index)
  • @@ -1004,7 +1004,7 @@ implements
  • buildDetailedErrorMsg

    -
    private String buildDetailedErrorMsg(String string,
    +
    private String buildDetailedErrorMsg(String string,
                                          int index)
  • @@ -1014,7 +1014,7 @@ implements
  • waitUntilDone

    -
    public void waitUntilDone()
    +
    public void waitUntilDone()
                        throws InterruptedIOException
    Description copied from interface: AsyncProcess.AsyncRequestFuture
    Wait until all tasks are executed, successfully or not.
    @@ -1032,7 +1032,7 @@ implements
  • waitUntilDone

    -
    private boolean waitUntilDone(long cutoff)
    +
    private boolean waitUntilDone(long cutoff)
                            throws InterruptedException
    Throws:
    @@ -1046,7 +1046,7 @@ implements
  • hasError

    -
    public boolean hasError()
    +
    public boolean hasError()
    Specified by:
    hasError in interface AsyncProcess.AsyncRequestFuture
    @@ -1059,7 +1059,7 @@ implements
  • getFailedOperations

    -
    public List<? extends RowgetFailedOperations()
    +
    public List<? extends RowgetFailedOperations()
    Specified by:
    getFailedOperations in interface AsyncProcess.AsyncRequestFuture
    @@ -1072,7 +1072,7 @@ implements
  • getErrors

    -
    public RetriesExhaustedWithDetailsException getErrors()
    +
    public RetriesExhaustedWithDetailsException getErrors()
    Specified by:
    getErrors in interface AsyncProcess.AsyncRequestFuture
    @@ -1085,7 +1085,7 @@ implements
  • getResults

    -
    public Object[] getResults()
    +
    public Object[] getResults()
                         throws InterruptedIOException
    Specified by:
    http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.ListRowAccess.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.ListRowAccess.html b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.ListRowAccess.html index 726052c..9476771 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.ListRowAccess.html +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.ListRowAccess.html @@ -117,7 +117,7 @@ var activeTableTab = "activeTableTab";


    -
    public static class AsyncProcess.ListRowAccess<T>
    +
    public static class AsyncProcess.ListRowAccess<T>
     extends Object
     implements RowAccess<T>
  • @@ -221,7 +221,7 @@ implements
  • data

    -
    private final List<T> data
    +
    private final List<T> data
  • @@ -238,7 +238,7 @@ implements
  • ListRowAccess

    -
    ListRowAccess(List<T> data)
    +
    ListRowAccess(List<T> data)
  • @@ -255,7 +255,7 @@ implements
  • size

    -
    public int size()
    +
    public int size()
    Specified by:
    size in interface RowAccess<T>
    @@ -270,7 +270,7 @@ implements
  • isEmpty

    -
    public boolean isEmpty()
    +
    public boolean isEmpty()
    Specified by:
    isEmpty in interface RowAccess<T>
    @@ -285,7 +285,7 @@ implements
  • iterator

    -
    public Iterator<Titerator()
    +
    public Iterator<Titerator()
    Specified by:
    iterator in interface Iterable<T>
    http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RequestSizeChecker.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RequestSizeChecker.html b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RequestSizeChecker.html index 602b1b9..0b3075e 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RequestSizeChecker.html +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RequestSizeChecker.html @@ -117,7 +117,7 @@ var activeTableTab = "activeTableTab";


    -
    static class AsyncProcess.RequestSizeChecker
    +
    static class AsyncProcess.RequestSizeChecker
     extends Object
     implements AsyncProcess.RowChecker
    limit the request size for each regionserver.
    @@ -241,7 +241,7 @@ implements
  • maxHeapSizePerRequest

    -
    private final long maxHeapSizePerRequest
    +
    private final long maxHeapSizePerRequest
  • @@ -250,7 +250,7 @@ implements
  • serverRequestSizes

    -
    private final Map<ServerName,Long> serverRequestSizes
    +
    private final Map<ServerName,Long> serverRequestSizes
  • @@ -267,7 +267,7 @@ implements
  • RequestSizeChecker

    -
    RequestSizeChecker(long maxHeapSizePerRequest)
    +
    RequestSizeChecker(long maxHeapSizePerRequest)
  • @@ -284,7 +284,7 @@ implements
  • reset

    -
    public void reset()
    +
    public void reset()
    Description copied from interface: AsyncProcess.RowChecker
    Reset the inner state.
    @@ -299,7 +299,7 @@ implements
  • canTakeOperation

    -
    public AsyncProcess.RowChecker.ReturnCode canTakeOperation(HRegionLocation loc,
    +
    public AsyncProcess.RowChecker.ReturnCode canTakeOperation(HRegionLocation loc,
                                                                long rowSize)
    Specified by:
    @@ -313,7 +313,7 @@ implements
  • notifyFinal

    -
    public void notifyFinal(AsyncProcess.RowChecker.ReturnCode code,
    +
    public void notifyFinal(AsyncProcess.RowChecker.ReturnCode code,
                             HRegionLocation loc,
                             long rowSize)
    Description copied from interface: AsyncProcess.RowChecker
    http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.Retry.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.Retry.html b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.Retry.html index c0144d8..68c846b 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.Retry.html +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.Retry.html @@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab";


  • -
    private static enum AsyncProcess.Retry
    +
    private static enum AsyncProcess.Retry
     extends Enum<AsyncProcess.Retry>
    For AsyncRequestFutureImpl#manageError(int, Row, Retry, Throwable, ServerName). Only used to make logging more clear, we don't actually care why we don't retry.
    @@ -221,7 +221,7 @@ the order they are declared.
  • @@ -230,7 +230,7 @@ the order they are declared. @@ -239,7 +239,7 @@ the order they are declared. @@ -248,7 +248,7 @@ the order they are declared. @@ -257,7 +257,7 @@ the order they are declared.
  • @@ -274,7 +274,7 @@ the order they are declared.
    • values

      -
      public static AsyncProcess.Retry[] values()
      +
      public static AsyncProcess.Retry[] values()
      Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows: @@ -294,7 +294,7 @@ for (AsyncProcess.Retry c : AsyncProcess.Retry.values())
      • valueOf

        -
        public static AsyncProcess.Retry valueOf(String name)
        +
        public static AsyncProcess.Retry valueOf(String name)
        Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RowChecker.ReturnCode.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RowChecker.ReturnCode.html b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RowChecker.ReturnCode.html index 3504a5a..71d3bcc 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RowChecker.ReturnCode.html +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RowChecker.ReturnCode.html @@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab";


  • -
    public static enum AsyncProcess.RowChecker.ReturnCode
    +
    public static enum AsyncProcess.RowChecker.ReturnCode
     extends Enum<AsyncProcess.RowChecker.ReturnCode>
  • @@ -219,7 +219,7 @@ the order they are declared. @@ -229,7 +229,7 @@ the order they are declared. @@ -239,7 +239,7 @@ the order they are declared. @@ -257,7 +257,7 @@ the order they are declared.
    • values

      -
      public static AsyncProcess.RowChecker.ReturnCode[] values()
      +
      public static AsyncProcess.RowChecker.ReturnCode[] values()
      Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows: @@ -277,7 +277,7 @@ for (AsyncProcess.RowChecker.ReturnCode c : AsyncProcess.RowChecker.ReturnCode.v
      • valueOf

        -
        public static AsyncProcess.RowChecker.ReturnCode valueOf(String name)
        +
        public static AsyncProcess.RowChecker.ReturnCode valueOf(String name)
        Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f55baeba/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RowChecker.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RowChecker.html b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RowChecker.html index a95c765..b19d86b 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RowChecker.html +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.RowChecker.html @@ -109,7 +109,7 @@ var activeTableTab = "activeTableTab";


  • -
    static interface AsyncProcess.RowChecker
    +
    static interface AsyncProcess.RowChecker
    Provide a way to control the flow of rows iteration.
  • @@ -188,7 +188,7 @@ var activeTableTab = "activeTableTab"; @@ -198,7 +198,7 @@ var activeTableTab = "activeTableTab";