http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d434d867/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.html b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.html index 83430bd..7012c57 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.html +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.html @@ -205,107 +205,123 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#DEFAULT_START_LOG_ERRORS_AFTER_COUNT">DEFAULT_START_LOG_ERRORS_AFTER_COUNT</a></strong></code> </td> </tr> <tr class="rowColor"> +<td class="colFirst"><code>private static int</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#DEFAULT_THRESHOLD_TO_LOG_UNDONE_TASK_DETAILS">DEFAULT_THRESHOLD_TO_LOG_UNDONE_TASK_DETAILS</a></strong></code> </td> +</tr> +<tr class="altColor"> <td class="colFirst"><code>protected <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.BatchErrors.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.BatchErrors</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#globalErrors">globalErrors</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected long</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#id">id</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private static org.apache.commons.logging.Log</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#LOG">LOG</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>static <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#LOG_DETAILS_FOR_BATCH_ERROR">LOG_DETAILS_FOR_BATCH_ERROR</a></strong></code> <div class="block">Configuration to decide whether to log details for batch error</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#logBatchErrorDetails">logBatchErrorDetails</a></strong></code> <div class="block">Whether to log details for batch errors</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected int</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#maxConcurrentTasksPerRegion">maxConcurrentTasksPerRegion</a></strong></code> <div class="block">The number of tasks we run in parallel on a single region.</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>protected int</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#maxConcurrentTasksPerServer">maxConcurrentTasksPerServer</a></strong></code> <div class="block">The number of task simultaneously executed on a single region server.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected int</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#maxTotalConcurrentTasks">maxTotalConcurrentTasks</a></strong></code> <div class="block">The number of tasks simultaneously executed on the cluster.</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private static <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#NO_REQS_RESULT">NO_REQS_RESULT</a></strong></code> <div class="block">Return value from a submit that didn't contain any requests.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected int</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#numTries">numTries</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>protected long</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#pause">pause</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#pool">pool</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>static <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#PRIMARY_CALL_TIMEOUT_KEY">PRIMARY_CALL_TIMEOUT_KEY</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected long</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#primaryCallTimeoutMicroseconds">primaryCallTimeoutMicroseconds</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>protected <a href="../../../../../org/apache/hadoop/hbase/client/RpcRetryingCallerFactory.html" title="class in org.apache.hadoop.hbase.client">RpcRetryingCallerFactory</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#rpcCallerFactory">rpcCallerFactory</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcControllerFactory.html" title="class in org.apache.hadoop.hbase.ipc">RpcControllerFactory</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#rpcFactory">rpcFactory</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>protected int</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#serverTrackerTimeout">serverTrackerTimeout</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>static <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#START_LOG_ERRORS_AFTER_COUNT_KEY">START_LOG_ERRORS_AFTER_COUNT_KEY</a></strong></code> <div class="block">Configure the number of failures after which the client will start logging.</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private int</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#startLogErrorsCnt">startLogErrorsCnt</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true"; title="class or interface in java.util.concurrent">ConcurrentMap</a><byte[],<a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a>></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#taskCounterPerRegion">taskCounterPerRegion</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true"; title="class or interface in java.util.concurrent">ConcurrentMap</a><<a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a>></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#taskCounterPerServer">taskCounterPerServer</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicLong</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#tasksInProgress">tasksInProgress</a></strong></code> </td> </tr> +<tr class="altColor"> +<td class="colFirst"><code>private int</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#THRESHOLD_TO_LOG_REGION_DETAILS">THRESHOLD_TO_LOG_REGION_DETAILS</a></strong></code> </td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>private static <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#THRESHOLD_TO_LOG_UNDONE_TASK_DETAILS">THRESHOLD_TO_LOG_UNDONE_TASK_DETAILS</a></strong></code> </td> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>private int</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#thresholdToLogUndoneTaskDetails">thresholdToLogUndoneTaskDetails</a></strong></code> </td> +</tr> <tr class="rowColor"> <td class="colFirst"><code>protected int</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#timeout">timeout</a></strong></code> </td> @@ -436,12 +452,16 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#isReplicaGet(org.apache.hadoop.hbase.client.Row)">isReplicaGet</a></strong>(<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a> row)</code> </td> </tr> <tr class="altColor"> +<td class="colFirst"><code>private void</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#logDetailsOfUndoneTasks(long)">logDetailsOfUndoneTasks</a></strong>(long taskInProgress)</code> </td> +</tr> +<tr class="rowColor"> <td class="colFirst"><code>private static void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#setNonce(org.apache.hadoop.hbase.client.NonceGenerator,%20org.apache.hadoop.hbase.client.Row,%20org.apache.hadoop.hbase.client.Action)">setNonce</a></strong>(<a href="../../../../../org/apache/hadoop/hbase/client/NonceGenerator.html" title="interface in org.apache.hadoop.hbase.client">NonceGenerator</a> ng, <a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a> r, <a href="../../../../../org/apache/hadoop/hbase/client/Action.html" title="class in org.apache.hadoop.hbase.client">Action</a><<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> action)</code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code><CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#submit(java.util.concurrent.ExecutorService,%20org.apache.hadoop.hbase.TableName,%20java.util.List,%20boolean,%20org.apache.hadoop.hbase.client.coprocessor.Batch.Callback,%20boolean)">submit</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool, <a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, @@ -452,7 +472,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <div class="block">Extract from the rows list what we can submit.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code><CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#submit(org.apache.hadoop.hbase.TableName,%20java.util.List,%20boolean,%20org.apache.hadoop.hbase.client.coprocessor.Batch.Callback,%20boolean)">submit</a></strong>(<a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><? extends <a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> rows, @@ -462,7 +482,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <div class="block">See <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#submit(java.util.concurrent.ExecutorService,%20org.apache.hadoop.hbase.TableName,%20java.util.List,%20boolean,%20org.apache.hadoop.hbase.client.coprocessor.Batch.Callback,%20boolean)"><code>submit(ExecutorService, TableName, List, boolean, Batch.Callback, boolean)</code></a>.</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code><CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#submitAll(java.util.concurrent.ExecutorService,%20org.apache.hadoop.hbase.TableName,%20java.util.List,%20org.apache.hadoop.hbase.client.coprocessor.Batch.Callback,%20java.lang.Object[])">submitAll</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool, <a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, @@ -470,7 +490,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <a href="../../../../../org/apache/hadoop/hbase/client/coprocessor/Batch.Callback.html" title="interface in org.apache.hadoop.hbase.client.coprocessor">Batch.Callback</a><CResult> callback, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>[] results)</code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code><CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#submitAll(java.util.concurrent.ExecutorService,%20org.apache.hadoop.hbase.TableName,%20java.util.List,%20org.apache.hadoop.hbase.client.coprocessor.Batch.Callback,%20java.lang.Object[],%20org.apache.hadoop.hbase.client.PayloadCarryingServerCallable,%20int)">submitAll</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool, <a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, @@ -482,7 +502,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <div class="block">Submit immediately the list of rows, whatever the server status.</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code><CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#submitAll(org.apache.hadoop.hbase.TableName,%20java.util.List,%20org.apache.hadoop.hbase.client.coprocessor.Batch.Callback,%20java.lang.Object[])">submitAll</a></strong>(<a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><? extends <a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> rows, @@ -491,7 +511,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <div class="block">See <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#submitAll(java.util.concurrent.ExecutorService,%20org.apache.hadoop.hbase.TableName,%20java.util.List,%20org.apache.hadoop.hbase.client.coprocessor.Batch.Callback,%20java.lang.Object[])"><code>submitAll(ExecutorService, TableName, List, Batch.Callback, Object[])</code></a>.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>(package private) <CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#submitMultiActions(org.apache.hadoop.hbase.TableName,%20java.util.List,%20long,%20org.apache.hadoop.hbase.client.coprocessor.Batch.Callback,%20java.lang.Object[],%20boolean,%20java.util.List,%20java.util.List,%20java.util.Map,%20java.util.concurrent.ExecutorService)">submitMultiActions</a></strong>(<a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../org/apache/hadoop/hbase/client/Action.html" title="class in org.apache.hadoop.hbase.client">Action</a><<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>>> retainedActions, @@ -504,30 +524,33 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a>,<a href="../../../../../org/apache/hadoop/hbase/client/MultiAction.html" title="class in org.apache.hadoop.hbase.client">MultiAction</a><<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>>> actionsByServer, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool)</code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#updateStats(org.apache.hadoop.hbase.ServerName,%20java.util.Map)">updateStats</a></strong>(<a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> server, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><byte[],<a href="../../../../../org/apache/hadoop/hbase/client/MultiResponse.RegionResult.html" title="class in org.apache.hadoop.hbase.client">MultiResponse.RegionResult</a>> results)</code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code><a href="../../../../../org/apache/hadoop/hbase/client/RetriesExhaustedWithDetailsException.html" title="class in org.apache.hadoop.hbase.client">RetriesExhaustedWithDetailsException</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#waitForAllPreviousOpsAndReset(java.util.List)">waitForAllPreviousOpsAndReset</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> failedRows)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#waitForAllPreviousOpsAndReset(java.util.List,%20java.lang.String)">waitForAllPreviousOpsAndReset</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> failedRows, + <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> tableName)</code> <div class="block">Only used w/useGlobalErrors ctor argument, for HTable backward compat.</div> </td> </tr> +<tr class="altColor"> +<td class="colFirst"><code>(package private) void</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#waitForMaximumCurrentTasks(int,%20java.util.concurrent.atomic.AtomicLong,%20long,%20java.lang.String)">waitForMaximumCurrentTasks</a></strong>(int max, + <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicLong</a> tasksInProgress, + long id, + <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> tableName)</code> </td> +</tr> <tr class="rowColor"> <td class="colFirst"><code>private void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#waitForMaximumCurrentTasks(int)">waitForMaximumCurrentTasks</a></strong>(int max)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#waitForMaximumCurrentTasks(int,%20java.lang.String)">waitForMaximumCurrentTasks</a></strong>(int max, + <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> tableName)</code> <div class="block">Wait until the async does not have more than max tasks in progress.</div> </td> </tr> <tr class="altColor"> -<td class="colFirst"><code>(package private) static void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#waitForMaximumCurrentTasks(int,%20java.util.concurrent.atomic.AtomicLong,%20long)">waitForMaximumCurrentTasks</a></strong>(int max, - <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicLong</a> tasksInProgress, - long id)</code> </td> -</tr> -<tr class="rowColor"> <td class="colFirst"><code>(package private) void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#waitUntilDone()">waitUntilDone</a></strong>()</code> </td> </tr> @@ -616,13 +639,52 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.client.AsyncProcess.LOG_DETAILS_FOR_BATCH_ERROR">Constant Field Values</a></dd></dl> </li> </ul> +<a name="thresholdToLogUndoneTaskDetails"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>thresholdToLogUndoneTaskDetails</h4> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.123">thresholdToLogUndoneTaskDetails</a></pre> +</li> +</ul> +<a name="THRESHOLD_TO_LOG_UNDONE_TASK_DETAILS"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>THRESHOLD_TO_LOG_UNDONE_TASK_DETAILS</h4> +<pre>private static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.124">THRESHOLD_TO_LOG_UNDONE_TASK_DETAILS</a></pre> +<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.client.AsyncProcess.THRESHOLD_TO_LOG_UNDONE_TASK_DETAILS">Constant Field Values</a></dd></dl> +</li> +</ul> +<a name="DEFAULT_THRESHOLD_TO_LOG_UNDONE_TASK_DETAILS"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>DEFAULT_THRESHOLD_TO_LOG_UNDONE_TASK_DETAILS</h4> +<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.126">DEFAULT_THRESHOLD_TO_LOG_UNDONE_TASK_DETAILS</a></pre> +<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.client.AsyncProcess.DEFAULT_THRESHOLD_TO_LOG_UNDONE_TASK_DETAILS">Constant Field Values</a></dd></dl> +</li> +</ul> +<a name="THRESHOLD_TO_LOG_REGION_DETAILS"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>THRESHOLD_TO_LOG_REGION_DETAILS</h4> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.127">THRESHOLD_TO_LOG_REGION_DETAILS</a></pre> +<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.client.AsyncProcess.THRESHOLD_TO_LOG_REGION_DETAILS">Constant Field Values</a></dd></dl> +</li> +</ul> <a name="NO_REQS_RESULT"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>NO_REQS_RESULT</h4> -<pre>private static final <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.141">NO_REQS_RESULT</a></pre> +<pre>private static final <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.147">NO_REQS_RESULT</a></pre> <div class="block">Return value from a submit that didn't contain any requests.</div> </li> </ul> @@ -632,7 +694,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>id</h4> -<pre>protected final long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.192">id</a></pre> +<pre>protected final long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.198">id</a></pre> </li> </ul> <a name="connection"> @@ -641,7 +703,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>connection</h4> -<pre>protected final <a href="../../../../../org/apache/hadoop/hbase/client/ClusterConnection.html" title="interface in org.apache.hadoop.hbase.client">ClusterConnection</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.194">connection</a></pre> +<pre>protected final <a href="../../../../../org/apache/hadoop/hbase/client/ClusterConnection.html" title="interface in org.apache.hadoop.hbase.client">ClusterConnection</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.200">connection</a></pre> </li> </ul> <a name="rpcCallerFactory"> @@ -650,7 +712,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>rpcCallerFactory</h4> -<pre>protected final <a href="../../../../../org/apache/hadoop/hbase/client/RpcRetryingCallerFactory.html" title="class in org.apache.hadoop.hbase.client">RpcRetryingCallerFactory</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.195">rpcCallerFactory</a></pre> +<pre>protected final <a href="../../../../../org/apache/hadoop/hbase/client/RpcRetryingCallerFactory.html" title="class in org.apache.hadoop.hbase.client">RpcRetryingCallerFactory</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.201">rpcCallerFactory</a></pre> </li> </ul> <a name="rpcFactory"> @@ -659,7 +721,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>rpcFactory</h4> -<pre>protected final <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcControllerFactory.html" title="class in org.apache.hadoop.hbase.ipc">RpcControllerFactory</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.196">rpcFactory</a></pre> +<pre>protected final <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcControllerFactory.html" title="class in org.apache.hadoop.hbase.ipc">RpcControllerFactory</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.202">rpcFactory</a></pre> </li> </ul> <a name="globalErrors"> @@ -668,7 +730,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>globalErrors</h4> -<pre>protected final <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.BatchErrors.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.BatchErrors</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.197">globalErrors</a></pre> +<pre>protected final <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.BatchErrors.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.BatchErrors</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.203">globalErrors</a></pre> </li> </ul> <a name="pool"> @@ -677,7 +739,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>pool</h4> -<pre>protected final <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.198">pool</a></pre> +<pre>protected final <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.204">pool</a></pre> </li> </ul> <a name="tasksInProgress"> @@ -686,7 +748,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>tasksInProgress</h4> -<pre>protected final <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicLong</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.200">tasksInProgress</a></pre> +<pre>protected final <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicLong</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.206">tasksInProgress</a></pre> </li> </ul> <a name="taskCounterPerRegion"> @@ -695,7 +757,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>taskCounterPerRegion</h4> -<pre>protected final <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true"; title="class or interface in java.util.concurrent">ConcurrentMap</a><byte[],<a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.201">taskCounterPerRegion</a></pre> +<pre>protected final <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true"; title="class or interface in java.util.concurrent">ConcurrentMap</a><byte[],<a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.207">taskCounterPerRegion</a></pre> </li> </ul> <a name="taskCounterPerServer"> @@ -704,7 +766,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>taskCounterPerServer</h4> -<pre>protected final <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true"; title="class or interface in java.util.concurrent">ConcurrentMap</a><<a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.203">taskCounterPerServer</a></pre> +<pre>protected final <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true"; title="class or interface in java.util.concurrent">ConcurrentMap</a><<a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.209">taskCounterPerServer</a></pre> </li> </ul> <a name="startLogErrorsCnt"> @@ -713,7 +775,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>startLogErrorsCnt</h4> -<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.207">startLogErrorsCnt</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.213">startLogErrorsCnt</a></pre> </li> </ul> <a name="maxTotalConcurrentTasks"> @@ -722,7 +784,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>maxTotalConcurrentTasks</h4> -<pre>protected final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.212">maxTotalConcurrentTasks</a></pre> +<pre>protected final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.218">maxTotalConcurrentTasks</a></pre> <div class="block">The number of tasks simultaneously executed on the cluster.</div> </li> </ul> @@ -732,7 +794,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>maxConcurrentTasksPerRegion</h4> -<pre>protected final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.220">maxConcurrentTasksPerRegion</a></pre> +<pre>protected final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.226">maxConcurrentTasksPerRegion</a></pre> <div class="block">The number of tasks we run in parallel on a single region. With 1 (the default) , we ensure that the ordering of the queries is respected: we don't start a set of operations on a region before the previous one is done. As well, this limits @@ -745,7 +807,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>maxConcurrentTasksPerServer</h4> -<pre>protected final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.225">maxConcurrentTasksPerServer</a></pre> +<pre>protected final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.231">maxConcurrentTasksPerServer</a></pre> <div class="block">The number of task simultaneously executed on a single region server.</div> </li> </ul> @@ -755,7 +817,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>pause</h4> -<pre>protected final long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.226">pause</a></pre> +<pre>protected final long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.232">pause</a></pre> </li> </ul> <a name="numTries"> @@ -764,7 +826,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>numTries</h4> -<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.227">numTries</a></pre> +<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.233">numTries</a></pre> </li> </ul> <a name="serverTrackerTimeout"> @@ -773,7 +835,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>serverTrackerTimeout</h4> -<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.228">serverTrackerTimeout</a></pre> +<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.234">serverTrackerTimeout</a></pre> </li> </ul> <a name="timeout"> @@ -782,7 +844,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>timeout</h4> -<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.229">timeout</a></pre> +<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.235">timeout</a></pre> </li> </ul> <a name="primaryCallTimeoutMicroseconds"> @@ -791,7 +853,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>primaryCallTimeoutMicroseconds</h4> -<pre>protected long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.230">primaryCallTimeoutMicroseconds</a></pre> +<pre>protected long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.236">primaryCallTimeoutMicroseconds</a></pre> </li> </ul> <a name="logBatchErrorDetails"> @@ -800,7 +862,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>logBatchErrorDetails</h4> -<pre>private final boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.232">logBatchErrorDetails</a></pre> +<pre>private final boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.238">logBatchErrorDetails</a></pre> <div class="block">Whether to log details for batch errors</div> </li> </ul> @@ -818,7 +880,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>AsyncProcess</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.276">AsyncProcess</a>(<a href="../../../../../org/apache/hadoop/hbase/client/ClusterConnection.html" title="interface in org.apache.hadoop.hbase.client">ClusterConnection</a> hc, +<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.282">AsyncProcess</a>(<a href="../../../../../org/apache/hadoop/hbase/client/ClusterConnection.html" title="interface in org.apache.hadoop.hbase.client">ClusterConnection</a> hc, org.apache.hadoop.conf.Configuration conf, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool, <a href="../../../../../org/apache/hadoop/hbase/client/RpcRetryingCallerFactory.html" title="class in org.apache.hadoop.hbase.client">RpcRetryingCallerFactory</a> rpcCaller, @@ -840,7 +902,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getPool</h4> -<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.341">getPool</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool)</pre> +<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.351">getPool</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool)</pre> <dl><dt><span class="strong">Returns:</span></dt><dd>pool if non null, otherwise returns this.pool if non null, otherwise throws RuntimeException</dd></dl> </li> @@ -851,7 +913,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>submit</h4> -<pre>public <CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.355">submit</a>(<a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, +<pre>public <CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.365">submit</a>(<a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><? extends <a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> rows, boolean atLeastOne, <a href="../../../../../org/apache/hadoop/hbase/client/coprocessor/Batch.Callback.html" title="interface in org.apache.hadoop.hbase.client.coprocessor">Batch.Callback</a><CResult> callback, @@ -869,7 +931,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>submit</h4> -<pre>public <CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.373">submit</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool, +<pre>public <CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.383">submit</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool, <a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><? extends <a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> rows, boolean atLeastOne, @@ -890,7 +952,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>submitMultiActions</h4> -<pre><CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.447">submitMultiActions</a>(<a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, +<pre><CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.457">submitMultiActions</a>(<a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../org/apache/hadoop/hbase/client/Action.html" title="class in org.apache.hadoop.hbase.client">Action</a><<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>>> retainedActions, long nonceGroup, <a href="../../../../../org/apache/hadoop/hbase/client/coprocessor/Batch.Callback.html" title="interface in org.apache.hadoop.hbase.client.coprocessor">Batch.Callback</a><CResult> callback, @@ -908,7 +970,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>addAction</h4> -<pre>private static void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.475">addAction</a>(<a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> server, +<pre>private static void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.485">addAction</a>(<a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> server, byte[] regionName, <a href="../../../../../org/apache/hadoop/hbase/client/Action.html" title="class in org.apache.hadoop.hbase.client">Action</a><<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> action, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a>,<a href="../../../../../org/apache/hadoop/hbase/client/MultiAction.html" title="class in org.apache.hadoop.hbase.client">MultiAction</a><<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>>> actionsByServer, @@ -923,7 +985,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>canTakeOperation</h4> -<pre>protected boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.497">canTakeOperation</a>(<a href="../../../../../org/apache/hadoop/hbase/HRegionLocation.html" title="class in org.apache.hadoop.hbase">HRegionLocation</a> loc, +<pre>protected boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.507">canTakeOperation</a>(<a href="../../../../../org/apache/hadoop/hbase/HRegionLocation.html" title="class in org.apache.hadoop.hbase">HRegionLocation</a> loc, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/hadoop/hbase/HRegionInfo.html" title="class in org.apache.hadoop.hbase">HRegionInfo</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Boolean.html?is-external=true"; title="class or interface in java.lang">Boolean</a>> regionsIncluded, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Boolean.html?is-external=true"; title="class or interface in java.lang">Boolean</a>> serversIncluded)</pre> <div class="block">Check if we should send new operations to this region or region server. @@ -939,7 +1001,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>submitAll</h4> -<pre>public <CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.560">submitAll</a>(<a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, +<pre>public <CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.570">submitAll</a>(<a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><? extends <a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> rows, <a href="../../../../../org/apache/hadoop/hbase/client/coprocessor/Batch.Callback.html" title="interface in org.apache.hadoop.hbase.client.coprocessor">Batch.Callback</a><CResult> callback, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>[] results)</pre> @@ -953,7 +1015,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>submitAll</h4> -<pre>public <CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.565">submitAll</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool, +<pre>public <CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.575">submitAll</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool, <a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><? extends <a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> rows, <a href="../../../../../org/apache/hadoop/hbase/client/coprocessor/Batch.Callback.html" title="interface in org.apache.hadoop.hbase.client.coprocessor">Batch.Callback</a><CResult> callback, @@ -966,7 +1028,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>submitAll</h4> -<pre>public <CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.579">submitAll</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool, +<pre>public <CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.589">submitAll</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool, <a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><? extends <a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> rows, <a href="../../../../../org/apache/hadoop/hbase/client/coprocessor/Batch.Callback.html" title="interface in org.apache.hadoop.hbase.client.coprocessor">Batch.Callback</a><CResult> callback, @@ -984,7 +1046,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>setNonce</h4> -<pre>private static void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.606">setNonce</a>(<a href="../../../../../org/apache/hadoop/hbase/client/NonceGenerator.html" title="interface in org.apache.hadoop.hbase.client">NonceGenerator</a> ng, +<pre>private static void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.616">setNonce</a>(<a href="../../../../../org/apache/hadoop/hbase/client/NonceGenerator.html" title="interface in org.apache.hadoop.hbase.client">NonceGenerator</a> ng, <a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a> r, <a href="../../../../../org/apache/hadoop/hbase/client/Action.html" title="class in org.apache.hadoop.hbase.client">Action</a><<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> action)</pre> </li> @@ -995,7 +1057,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>updateStats</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1713">updateStats</a>(<a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> server, +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1723">updateStats</a>(<a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> server, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><byte[],<a href="../../../../../org/apache/hadoop/hbase/client/MultiResponse.RegionResult.html" title="class in org.apache.hadoop.hbase.client">MultiResponse.RegionResult</a>> results)</pre> </li> </ul> @@ -1005,7 +1067,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>createAsyncRequestFuture</h4> -<pre>protected <CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFutureImpl</a><CResult> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1730">createAsyncRequestFuture</a>(<a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, +<pre>protected <CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFutureImpl</a><CResult> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1740">createAsyncRequestFuture</a>(<a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../org/apache/hadoop/hbase/client/Action.html" title="class in org.apache.hadoop.hbase.client">Action</a><<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>>> actions, long nonceGroup, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool, @@ -1022,7 +1084,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>createAsyncRequestFuture</h4> -<pre>protected <CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFutureImpl</a><CResult> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1741">createAsyncRequestFuture</a>(<a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, +<pre>protected <CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFutureImpl</a><CResult> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1751">createAsyncRequestFuture</a>(<a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../org/apache/hadoop/hbase/client/Action.html" title="class in org.apache.hadoop.hbase.client">Action</a><<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>>> actions, long nonceGroup, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool, @@ -1037,7 +1099,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>createCallable</h4> -<pre>protected <a href="../../../../../org/apache/hadoop/hbase/client/MultiServerCallable.html" title="class in org.apache.hadoop.hbase.client">MultiServerCallable</a><<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1752">createCallable</a>(<a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> server, +<pre>protected <a href="../../../../../org/apache/hadoop/hbase/client/MultiServerCallable.html" title="class in org.apache.hadoop.hbase.client">MultiServerCallable</a><<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1762">createCallable</a>(<a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> server, <a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, <a href="../../../../../org/apache/hadoop/hbase/client/MultiAction.html" title="class in org.apache.hadoop.hbase.client">MultiAction</a><<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> multi)</pre> <div class="block">Create a callable. Isolated to be easily overridden in the tests.</div> @@ -1049,7 +1111,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>createCaller</h4> -<pre>protected <a href="../../../../../org/apache/hadoop/hbase/client/RpcRetryingCaller.html" title="interface in org.apache.hadoop.hbase.client">RpcRetryingCaller</a><<a href="../../../../../org/apache/hadoop/hbase/client/MultiResponse.html" title="class in org.apache.hadoop.hbase.client">MultiResponse</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1761">createCaller</a>(<a href="../../../../../org/apache/hadoop/hbase/client/PayloadCarryingServerCallable.html" title="class in org.apache.hadoop.hbase.client">PayloadCarryingServerCallable</a> callable)</pre> +<pre>protected <a href="../../../../../org/apache/hadoop/hbase/client/RpcRetryingCaller.html" title="interface in org.apache.hadoop.hbase.client">RpcRetryingCaller</a><<a href="../../../../../org/apache/hadoop/hbase/client/MultiResponse.html" title="class in org.apache.hadoop.hbase.client">MultiResponse</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1771">createCaller</a>(<a href="../../../../../org/apache/hadoop/hbase/client/PayloadCarryingServerCallable.html" title="class in org.apache.hadoop.hbase.client">PayloadCarryingServerCallable</a> callable)</pre> <div class="block">Create a caller. Isolated to be easily overridden in the tests.</div> </li> </ul> @@ -1059,65 +1121,77 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>waitUntilDone</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1767">waitUntilDone</a>() +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1777">waitUntilDone</a>() throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/InterruptedIOException.html?is-external=true"; title="class or interface in java.io">InterruptedIOException</a></pre> <dl><dt><span class="strong">Throws:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/InterruptedIOException.html?is-external=true"; title="class or interface in java.io">InterruptedIOException</a></code></dd></dl> </li> </ul> -<a name="waitForMaximumCurrentTasks(int)"> +<a name="waitForMaximumCurrentTasks(int, java.lang.String)"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>waitForMaximumCurrentTasks</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1772">waitForMaximumCurrentTasks</a>(int max) +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1782">waitForMaximumCurrentTasks</a>(int max, + <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> tableName) throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/InterruptedIOException.html?is-external=true"; title="class or interface in java.io">InterruptedIOException</a></pre> <div class="block">Wait until the async does not have more than max tasks in progress.</div> <dl><dt><span class="strong">Throws:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/InterruptedIOException.html?is-external=true"; title="class or interface in java.io">InterruptedIOException</a></code></dd></dl> </li> </ul> -<a name="waitForMaximumCurrentTasks(int, java.util.concurrent.atomic.AtomicLong, long)"> +<a name="waitForMaximumCurrentTasks(int, java.util.concurrent.atomic.AtomicLong, long, java.lang.String)"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>waitForMaximumCurrentTasks</h4> -<pre>static void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1778">waitForMaximumCurrentTasks</a>(int max, +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1789">waitForMaximumCurrentTasks</a>(int max, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicLong</a> tasksInProgress, - long id) - throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/InterruptedIOException.html?is-external=true"; title="class or interface in java.io">InterruptedIOException</a></pre> + long id, + <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> tableName) + throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/InterruptedIOException.html?is-external=true"; title="class or interface in java.io">InterruptedIOException</a></pre> <dl><dt><span class="strong">Throws:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/InterruptedIOException.html?is-external=true"; title="class or interface in java.io">InterruptedIOException</a></code></dd></dl> </li> </ul> +<a name="logDetailsOfUndoneTasks(long)"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>logDetailsOfUndoneTasks</h4> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1820">logDetailsOfUndoneTasks</a>(long taskInProgress)</pre> +</li> +</ul> <a name="hasError()"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>hasError</h4> -<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1810">hasError</a>()</pre> +<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1844">hasError</a>()</pre> <div class="block">Only used w/useGlobalErrors ctor argument, for HTable backward compat.</div> <dl><dt><span class="strong">Returns:</span></dt><dd>Whether there were any errors in any request since the last time - <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#waitForAllPreviousOpsAndReset(java.util.List)"><code>waitForAllPreviousOpsAndReset(List)</code></a> was called, or AP was created.</dd></dl> + <code>#waitForAllPreviousOpsAndReset(List)</code> was called, or AP was created.</dd></dl> </li> </ul> -<a name="waitForAllPreviousOpsAndReset(java.util.List)"> +<a name="waitForAllPreviousOpsAndReset(java.util.List, java.lang.String)"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>waitForAllPreviousOpsAndReset</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/RetriesExhaustedWithDetailsException.html" title="class in org.apache.hadoop.hbase.client">RetriesExhaustedWithDetailsException</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1823">waitForAllPreviousOpsAndReset</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> failedRows) +<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/RetriesExhaustedWithDetailsException.html" title="class in org.apache.hadoop.hbase.client">RetriesExhaustedWithDetailsException</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1858">waitForAllPreviousOpsAndReset</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> failedRows, + <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> tableName) throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/InterruptedIOException.html?is-external=true"; title="class or interface in java.io">InterruptedIOException</a></pre> <div class="block">Only used w/useGlobalErrors ctor argument, for HTable backward compat. Waits for all previous operations to finish, and returns errors and (optionally) failed operations themselves.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>failedRows</code> - an optional list into which the rows that failed since the last time - <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#waitForAllPreviousOpsAndReset(java.util.List)"><code>waitForAllPreviousOpsAndReset(List)</code></a> was called, or AP was created, are saved.</dd> -<dt><span class="strong">Returns:</span></dt><dd>all the errors since the last time <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#waitForAllPreviousOpsAndReset(java.util.List)"><code>waitForAllPreviousOpsAndReset(List)</code></a> + <code>#waitForAllPreviousOpsAndReset(List)</code> was called, or AP was created, are saved.</dd><dd><code>tableName</code> - name of the table</dd> +<dt><span class="strong">Returns:</span></dt><dd>all the errors since the last time <code>#waitForAllPreviousOpsAndReset(List)</code> was called, or AP was created.</dd> <dt><span class="strong">Throws:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/InterruptedIOException.html?is-external=true"; title="class or interface in java.io">InterruptedIOException</a></code></dd></dl> @@ -1129,7 +1203,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>incTaskCounters</h4> -<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1840">incTaskCounters</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><byte[]> regions, +<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1875">incTaskCounters</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><byte[]> regions, <a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> sn)</pre> <div class="block">increment the tasks counters for a given set of regions. MT safe.</div> </li> @@ -1140,7 +1214,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>decTaskCounters</h4> -<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1866">decTaskCounters</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><byte[]> regions, +<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1901">decTaskCounters</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><byte[]> regions, <a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> sn)</pre> <div class="block">Decrements the counters for a given region and the region server. MT Safe.</div> </li> @@ -1151,7 +1225,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>createServerErrorTracker</h4> -<pre>protected <a href="../../../../../org/apache/hadoop/hbase/client/ConnectionImplementation.ServerErrorTracker.html" title="class in org.apache.hadoop.hbase.client">ConnectionImplementation.ServerErrorTracker</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1886">createServerErrorTracker</a>()</pre> +<pre>protected <a href="../../../../../org/apache/hadoop/hbase/client/ConnectionImplementation.ServerErrorTracker.html" title="class in org.apache.hadoop.hbase.client">ConnectionImplementation.ServerErrorTracker</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1921">createServerErrorTracker</a>()</pre> <div class="block">Creates the server error tracker to use inside process. Currently, to preserve the main assumption about current retries, and to work well with the retry-limit-based calculation, the calculation is local per Process object. @@ -1165,7 +1239,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>isReplicaGet</h4> -<pre>private static boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1891">isReplicaGet</a>(<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a> row)</pre> +<pre>private static boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1926">isReplicaGet</a>(<a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a> row)</pre> </li> </ul> </li>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d434d867/devapidocs/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html b/devapidocs/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html index 241202e..6017ad7 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html +++ b/devapidocs/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html @@ -609,7 +609,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <li class="blockList"> <h4>setWriteBufferSize</h4> <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true"; title="class or interface in java.lang">@Deprecated</a> -public void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.266">setWriteBufferSize</a>(long writeBufferSize) +public void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.267">setWriteBufferSize</a>(long writeBufferSize) throws <a href="../../../../../org/apache/hadoop/hbase/client/RetriesExhaustedWithDetailsException.html" title="class in org.apache.hadoop.hbase.client">RetriesExhaustedWithDetailsException</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/io/InterruptedIOException.html?is-external=true"; title="class or interface in java.io">InterruptedIOException</a></pre> <div class="block"><span class="strong">Deprecated.</span> <i>Going away when we drop public support for <a href="../../../../../org/apache/hadoop/hbase/client/HTable.html" title="class in org.apache.hadoop.hbase.client"><code>HTable</code></a>.</i></div> @@ -626,7 +626,7 @@ public void <a href="../../../../../src-html/org/apache/hadoop/hbase/c <ul class="blockListLast"> <li class="blockList"> <h4>getWriteBufferSize</h4> -<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.278">getWriteBufferSize</a>()</pre> +<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.279">getWriteBufferSize</a>()</pre> <div class="block">Returns the maximum size in bytes of the write buffer for this HTable. <p> The default value comes from the configuration parameter <code>hbase.client.write.buffer</code>.</div> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d434d867/devapidocs/org/apache/hadoop/hbase/client/CompactType.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/client/CompactType.html b/devapidocs/org/apache/hadoop/hbase/client/CompactType.html index e54e929..9e1561e 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/CompactType.html +++ b/devapidocs/org/apache/hadoop/hbase/client/CompactType.html @@ -223,7 +223,7 @@ the order they are declared.</div> <ul class="blockList"> <li class="blockList"> <h4>values</h4> -<pre>public static <a href="../../../../../org/apache/hadoop/hbase/client/CompactType.html" title="enum in org.apache.hadoop.hbase.client">CompactType</a>[] <a href="../../../../../src-html/org/apache/hadoop/hbase/client/CompactType.html#line.29">values</a>()</pre> +<pre>public static <a href="../../../../../org/apache/hadoop/hbase/client/CompactType.html" title="enum in org.apache.hadoop.hbase.client">CompactType</a>[] <a href="../../../../../src-html/org/apache/hadoop/hbase/client/CompactType.html#line.24">values</a>()</pre> <div class="block">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: @@ -240,7 +240,7 @@ for (CompactType c : CompactType.values()) <ul class="blockListLast"> <li class="blockList"> <h4>valueOf</h4> -<pre>public static <a href="../../../../../org/apache/hadoop/hbase/client/CompactType.html" title="enum in org.apache.hadoop.hbase.client">CompactType</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/CompactType.html#line.29">valueOf</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> name)</pre> +<pre>public static <a href="../../../../../org/apache/hadoop/hbase/client/CompactType.html" title="enum in org.apache.hadoop.hbase.client">CompactType</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/CompactType.html#line.24">valueOf</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> name)</pre> <div class="block">Returns the enum constant of this type with the specified name. The string must match <i>exactly</i> an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are
