http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8569bd2f/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 41b1cb6..18ddd83 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.html +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.html @@ -96,7 +96,7 @@ <hr> <br> <pre><a href="../../../../../org/apache/hadoop/hbase/classification/InterfaceAudience.Private.html" title="annotation in org.apache.hadoop.hbase.classification">@InterfaceAudience.Private</a> - class <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.102">AsyncProcess</a> + class <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.106">AsyncProcess</a> extends <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></pre> <div class="block">This class allows a continuous flow of requests. It's written to be compatible with a synchronous caller such as HTable. @@ -166,17 +166,51 @@ 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.BatchErrors.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.BatchErrors</a></strong></code> </td> </tr> <tr class="rowColor"> +<td class="colFirst"><code>static class </code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.ListRowAccess.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.ListRowAccess</a><<a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.ListRowAccess.html" title="type parameter in AsyncProcess.ListRowAccess">T</a>></strong></code> </td> +</tr> +<tr class="altColor"> <td class="colFirst"><code>private static class </code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.ReplicaResultState.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.ReplicaResultState</a></strong></code> <div class="block">Sync point for calls to multiple replicas for the same user request (Get).</div> </td> </tr> +<tr class="rowColor"> +<td class="colFirst"><code>(package private) static class </code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.RequestSizeChecker.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.RequestSizeChecker</a></strong></code> +<div class="block">limit the request size for each regionserver.</div> +</td> +</tr> <tr class="altColor"> <td class="colFirst"><code>private static class </code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.Retry.html" title="enum in org.apache.hadoop.hbase.client">AsyncProcess.Retry</a></strong></code> <div class="block">For <code>AsyncRequestFutureImpl#manageError(int, Row, Retry, Throwable, ServerName)</code>.</div> </td> </tr> +<tr class="rowColor"> +<td class="colFirst"><code>(package private) static interface </code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.RowChecker.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.RowChecker</a></strong></code> +<div class="block">Provide a way to control the flow of rows iteration.</div> +</td> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>(package private) static class </code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.RowCheckerHost.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.RowCheckerHost</a></strong></code> +<div class="block">Collect all advices from checkers and make the final decision.</div> +</td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>(package private) static class </code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.SubmittedSizeChecker.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.SubmittedSizeChecker</a></strong></code> +<div class="block">limit the heapsize of total submitted data.</div> +</td> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>(package private) static class </code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.TaskCountChecker.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.TaskCountChecker</a></strong></code> +<div class="block">limit the max number of tasks in an AsyncProcess.</div> +</td> +</tr> </table> </li> </ul> @@ -201,6 +235,18 @@ 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#COUNTER">COUNTER</a></strong></code> </td> </tr> <tr class="altColor"> +<td class="colFirst"><code>static long</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#DEFAULT_HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE">DEFAULT_HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE</a></strong></code> +<div class="block">Default value of <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE"><code>HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE</code></a>.</div> +</td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>static long</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#DEFAULT_HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE">DEFAULT_HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE</a></strong></code> +<div class="block">Default value of <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE"><code>HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE</code></a>.</div> +</td> +</tr> +<tr class="altColor"> <td class="colFirst"><code>static int</code></td> <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> @@ -213,6 +259,18 @@ 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#globalErrors">globalErrors</a></strong></code> </td> </tr> <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#HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE">HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE</a></strong></code> +<div class="block">The maximum size of single RegionServer.</div> +</td> +</tr> +<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#HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE">HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE</a></strong></code> +<div class="block">The maximum size of submit.</div> +</td> +</tr> +<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> @@ -245,6 +303,16 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? </td> </tr> <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#maxHeapSizePerRequest">maxHeapSizePerRequest</a></strong></code> +<div class="block">The max heap size of all tasks simultaneously executed on a server.</div> +</td> +</tr> +<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#maxHeapSizeSubmit">maxHeapSizeSubmit</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#maxTotalConcurrentTasks">maxTotalConcurrentTasks</a></strong></code> <div class="block">The number of tasks simultaneously executed on the cluster.</div> @@ -375,14 +443,6 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? </td> </tr> <tr class="rowColor"> -<td class="colFirst"><code>protected boolean</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#canTakeOperation(org.apache.hadoop.hbase.HRegionLocation,%20java.util.Map,%20java.util.Map)">canTakeOperation</a></strong>(<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)</code> -<div class="block">Check if we should send new operations to this region or region server.</div> -</td> -</tr> -<tr class="altColor"> <td class="colFirst"><code>protected <CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFutureImpl</a><CResult></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#createAsyncRequestFuture(org.apache.hadoop.hbase.TableName,%20java.util.List,%20long,%20java.util.concurrent.ExecutorService,%20org.apache.hadoop.hbase.client.coprocessor.Batch.Callback,%20java.lang.Object[],%20boolean)">createAsyncRequestFuture</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>>> actions, @@ -392,7 +452,7 @@ 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/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>[] results, boolean needResults)</code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>protected <CResult> <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFutureImpl</a><CResult></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#createAsyncRequestFuture(org.apache.hadoop.hbase.TableName,%20java.util.List,%20long,%20java.util.concurrent.ExecutorService,%20org.apache.hadoop.hbase.client.coprocessor.Batch.Callback,%20java.lang.Object[],%20boolean,%20org.apache.hadoop.hbase.client.CancellableRegionServerCallable,%20int)">createAsyncRequestFuture</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>>> actions, @@ -404,7 +464,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <a href="../../../../../org/apache/hadoop/hbase/client/CancellableRegionServerCallable.html" title="class in org.apache.hadoop.hbase.client">CancellableRegionServerCallable</a> callable, int curTimeout)</code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>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>></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#createCallable(org.apache.hadoop.hbase.ServerName,%20org.apache.hadoop.hbase.TableName,%20org.apache.hadoop.hbase.client.MultiAction)">createCallable</a></strong>(<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, @@ -412,12 +472,16 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <div class="block">Create a callable.</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>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>></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#createCaller(org.apache.hadoop.hbase.client.CancellableRegionServerCallable)">createCaller</a></strong>(<a href="../../../../../org/apache/hadoop/hbase/client/CancellableRegionServerCallable.html" title="class in org.apache.hadoop.hbase.client">CancellableRegionServerCallable</a> callable)</code> <div class="block">Create a caller.</div> </td> </tr> +<tr class="rowColor"> +<td class="colFirst"><code>private <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.RowCheckerHost.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.RowCheckerHost</a></code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#createRowCheckerHost()">createRowCheckerHost</a></strong>()</code> </td> +</tr> <tr class="altColor"> <td class="colFirst"><code>protected <a href="../../../../../org/apache/hadoop/hbase/client/ConnectionImplementation.ServerErrorTracker.html" title="class in org.apache.hadoop.hbase.client">ConnectionImplementation.ServerErrorTracker</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#createServerErrorTracker()">createServerErrorTracker</a></strong>()</code> @@ -470,11 +534,22 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? 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, boolean needResults)</code> -<div class="block">Extract from the rows list what we can submit.</div> +<div class="block">See <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#submit(java.util.concurrent.ExecutorService,%20org.apache.hadoop.hbase.TableName,%20org.apache.hadoop.hbase.client.RowAccess,%20boolean,%20org.apache.hadoop.hbase.client.coprocessor.Batch.Callback,%20boolean)"><code>submit(ExecutorService, TableName, RowAccess, boolean, Batch.Callback, boolean)</code></a>.</div> </td> </tr> <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(java.util.concurrent.ExecutorService,%20org.apache.hadoop.hbase.TableName,%20org.apache.hadoop.hbase.client.RowAccess,%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, + <a href="../../../../../org/apache/hadoop/hbase/client/RowAccess.html" title="interface in org.apache.hadoop.hbase.client">RowAccess</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, + boolean needResults)</code> +<div class="block">Extract from the rows list what we can submit.</div> +</td> +</tr> +<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(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, boolean atLeastOne, @@ -483,6 +558,16 @@ 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"> +<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,%20org.apache.hadoop.hbase.client.RowAccess,%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="../../../../../org/apache/hadoop/hbase/client/RowAccess.html" title="interface in org.apache.hadoop.hbase.client">RowAccess</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, + boolean needResults)</code> +<div class="block">See <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#submit(java.util.concurrent.ExecutorService,%20org.apache.hadoop.hbase.TableName,%20org.apache.hadoop.hbase.client.RowAccess,%20boolean,%20org.apache.hadoop.hbase.client.coprocessor.Batch.Callback,%20boolean)"><code>submit(ExecutorService, TableName, RowAccess, boolean, Batch.Callback, boolean)</code></a>.</div> +</td> +</tr> <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, @@ -526,7 +611,7 @@ 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/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool)</code> </td> </tr> <tr class="altColor"> -<td class="colFirst"><code>private void</code></td> +<td class="colFirst"><code>protected 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> @@ -583,7 +668,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>LOG</h4> -<pre>private static final org.apache.commons.logging.Log <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.103">LOG</a></pre> +<pre>private static final org.apache.commons.logging.Log <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.107">LOG</a></pre> </li> </ul> <a name="COUNTER"> @@ -592,7 +677,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>COUNTER</h4> -<pre>protected static 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.104">COUNTER</a></pre> +<pre>protected static 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.108">COUNTER</a></pre> </li> </ul> <a name="PRIMARY_CALL_TIMEOUT_KEY"> @@ -601,7 +686,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>PRIMARY_CALL_TIMEOUT_KEY</h4> -<pre>public 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.106">PRIMARY_CALL_TIMEOUT_KEY</a></pre> +<pre>public 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.110">PRIMARY_CALL_TIMEOUT_KEY</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.client.AsyncProcess.PRIMARY_CALL_TIMEOUT_KEY">Constant Field Values</a></dd></dl> </li> </ul> @@ -611,7 +696,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>START_LOG_ERRORS_AFTER_COUNT_KEY</h4> -<pre>public 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.114">START_LOG_ERRORS_AFTER_COUNT_KEY</a></pre> +<pre>public 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.118">START_LOG_ERRORS_AFTER_COUNT_KEY</a></pre> <div class="block">Configure the number of failures after which the client will start logging. A few failures is fine: region moved, then is not opened, then is overloaded. We try to have an acceptable heuristic for the number of errors we don't log. 9 was chosen because we wait for 1s at @@ -625,7 +710,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>DEFAULT_START_LOG_ERRORS_AFTER_COUNT</h4> -<pre>public static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.116">DEFAULT_START_LOG_ERRORS_AFTER_COUNT</a></pre> +<pre>public static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.120">DEFAULT_START_LOG_ERRORS_AFTER_COUNT</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.client.AsyncProcess.DEFAULT_START_LOG_ERRORS_AFTER_COUNT">Constant Field Values</a></dd></dl> </li> </ul> @@ -635,7 +720,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>LOG_DETAILS_FOR_BATCH_ERROR</h4> -<pre>public 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.121">LOG_DETAILS_FOR_BATCH_ERROR</a></pre> +<pre>public 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.125">LOG_DETAILS_FOR_BATCH_ERROR</a></pre> <div class="block">Configuration to decide whether to log details for batch error</div> <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> @@ -646,7 +731,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.127">thresholdToLogUndoneTaskDetails</a></pre> </li> </ul> <a name="THRESHOLD_TO_LOG_UNDONE_TASK_DETAILS"> @@ -655,7 +740,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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> +<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.128">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> @@ -665,7 +750,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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> +<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.130">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> @@ -675,17 +760,61 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.131">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="HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE</h4> +<pre>public 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.136">HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE</a></pre> +<div class="block">The maximum size of single RegionServer.</div> +<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.client.AsyncProcess.HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE">Constant Field Values</a></dd></dl> +</li> +</ul> +<a name="DEFAULT_HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>DEFAULT_HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE</h4> +<pre>public static final long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.141">DEFAULT_HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE</a></pre> +<div class="block">Default value of <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE"><code>HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE</code></a>.</div> +<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.client.AsyncProcess.DEFAULT_HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE">Constant Field Values</a></dd></dl> +</li> +</ul> +<a name="HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE</h4> +<pre>public 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.146">HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE</a></pre> +<div class="block">The maximum size of submit.</div> +<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.client.AsyncProcess.HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE">Constant Field Values</a></dd></dl> +</li> +</ul> +<a name="DEFAULT_HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>DEFAULT_HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE</h4> +<pre>public static final long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.150">DEFAULT_HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE</a></pre> +<div class="block">Default value of <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE"><code>HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE</code></a>.</div> +<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.client.AsyncProcess.DEFAULT_HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE">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.147">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.170">NO_REQS_RESULT</a></pre> <div class="block">Return value from a submit that didn't contain any requests.</div> </li> </ul> @@ -695,7 +824,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.198">id</a></pre> +<pre>protected final long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.221">id</a></pre> </li> </ul> <a name="connection"> @@ -704,7 +833,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.200">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.223">connection</a></pre> </li> </ul> <a name="rpcCallerFactory"> @@ -713,7 +842,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.201">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.224">rpcCallerFactory</a></pre> </li> </ul> <a name="rpcFactory"> @@ -722,7 +851,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.202">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.225">rpcFactory</a></pre> </li> </ul> <a name="globalErrors"> @@ -731,7 +860,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.203">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.226">globalErrors</a></pre> </li> </ul> <a name="pool"> @@ -740,7 +869,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.204">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.227">pool</a></pre> </li> </ul> <a name="tasksInProgress"> @@ -749,7 +878,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.206">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.229">tasksInProgress</a></pre> </li> </ul> <a name="taskCounterPerRegion"> @@ -758,7 +887,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.207">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.230">taskCounterPerRegion</a></pre> </li> </ul> <a name="taskCounterPerServer"> @@ -767,7 +896,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.209">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.232">taskCounterPerServer</a></pre> </li> </ul> <a name="startLogErrorsCnt"> @@ -776,7 +905,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.213">startLogErrorsCnt</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.235">startLogErrorsCnt</a></pre> </li> </ul> <a name="maxTotalConcurrentTasks"> @@ -785,17 +914,36 @@ 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.218">maxTotalConcurrentTasks</a></pre> +<pre>protected final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.240">maxTotalConcurrentTasks</a></pre> <div class="block">The number of tasks simultaneously executed on the cluster.</div> </li> </ul> +<a name="maxHeapSizePerRequest"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>maxHeapSizePerRequest</h4> +<pre>protected final long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.245">maxHeapSizePerRequest</a></pre> +<div class="block">The max heap size of all tasks simultaneously executed on a server.</div> +</li> +</ul> +<a name="maxHeapSizeSubmit"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>maxHeapSizeSubmit</h4> +<pre>protected final long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.246">maxHeapSizeSubmit</a></pre> +</li> +</ul> <a name="maxConcurrentTasksPerRegion"> <!-- --> </a> <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.226">maxConcurrentTasksPerRegion</a></pre> +<pre>protected final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.253">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 @@ -808,7 +956,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.231">maxConcurrentTasksPerServer</a></pre> +<pre>protected final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.258">maxConcurrentTasksPerServer</a></pre> <div class="block">The number of task simultaneously executed on a single region server.</div> </li> </ul> @@ -818,7 +966,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.232">pause</a></pre> +<pre>protected final long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.259">pause</a></pre> </li> </ul> <a name="numTries"> @@ -827,7 +975,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.233">numTries</a></pre> +<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.260">numTries</a></pre> </li> </ul> <a name="serverTrackerTimeout"> @@ -836,7 +984,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.234">serverTrackerTimeout</a></pre> +<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.261">serverTrackerTimeout</a></pre> </li> </ul> <a name="timeout"> @@ -845,7 +993,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.235">timeout</a></pre> +<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.262">timeout</a></pre> </li> </ul> <a name="primaryCallTimeoutMicroseconds"> @@ -854,7 +1002,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.236">primaryCallTimeoutMicroseconds</a></pre> +<pre>protected long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.263">primaryCallTimeoutMicroseconds</a></pre> </li> </ul> <a name="logBatchErrorDetails"> @@ -863,7 +1011,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.238">logBatchErrorDetails</a></pre> +<pre>private final boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.265">logBatchErrorDetails</a></pre> <div class="block">Whether to log details for batch errors</div> </li> </ul> @@ -881,7 +1029,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.282">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.308">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, @@ -904,7 +1052,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.350">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.386">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> @@ -915,7 +1063,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.364">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.399">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, @@ -927,19 +1075,56 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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="submit(org.apache.hadoop.hbase.TableName, org.apache.hadoop.hbase.client.RowAccess, boolean, org.apache.hadoop.hbase.client.coprocessor.Batch.Callback, boolean)"> +<!-- --> +</a> +<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.408">submit</a>(<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/RowAccess.html" title="interface in org.apache.hadoop.hbase.client">RowAccess</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, + boolean needResults) + 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">See <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#submit(java.util.concurrent.ExecutorService,%20org.apache.hadoop.hbase.TableName,%20org.apache.hadoop.hbase.client.RowAccess,%20boolean,%20org.apache.hadoop.hbase.client.coprocessor.Batch.Callback,%20boolean)"><code>submit(ExecutorService, TableName, RowAccess, boolean, Batch.Callback, boolean)</code></a>. + Uses default ExecutorService for this AP (must have been created with one).</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="submit(java.util.concurrent.ExecutorService, org.apache.hadoop.hbase.TableName, java.util.List, boolean, org.apache.hadoop.hbase.client.coprocessor.Batch.Callback, boolean)"> <!-- --> </a> <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.382">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.417">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, <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, boolean needResults) 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">See <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#submit(java.util.concurrent.ExecutorService,%20org.apache.hadoop.hbase.TableName,%20org.apache.hadoop.hbase.client.RowAccess,%20boolean,%20org.apache.hadoop.hbase.client.coprocessor.Batch.Callback,%20boolean)"><code>submit(ExecutorService, TableName, RowAccess, boolean, Batch.Callback, boolean)</code></a>. + Uses the <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.ListRowAccess.html" title="class in org.apache.hadoop.hbase.client"><code>AsyncProcess.ListRowAccess</code></a> to wrap the <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util"><code>List</code></a>.</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="submit(java.util.concurrent.ExecutorService, org.apache.hadoop.hbase.TableName, org.apache.hadoop.hbase.client.RowAccess, boolean, org.apache.hadoop.hbase.client.coprocessor.Batch.Callback, boolean)"> +<!-- --> +</a> +<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.436">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="../../../../../org/apache/hadoop/hbase/client/RowAccess.html" title="interface in org.apache.hadoop.hbase.client">RowAccess</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, + boolean needResults) + 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">Extract from the rows list what we can submit. The rows we can not submit are kept in the list. Does not send requests to replicas (not currently used for anything other than streaming puts anyway).</div> @@ -948,13 +1133,22 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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="createRowCheckerHost()"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>createRowCheckerHost</h4> +<pre>private <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.RowCheckerHost.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.RowCheckerHost</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.514">createRowCheckerHost</a>()</pre> +</li> +</ul> <a name="submitMultiActions(org.apache.hadoop.hbase.TableName, java.util.List, long, org.apache.hadoop.hbase.client.coprocessor.Batch.Callback, java.lang.Object[], boolean, java.util.List, java.util.List, java.util.Map, java.util.concurrent.ExecutorService)"> <!-- --> </a> <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.456">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.526">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, @@ -972,7 +1166,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.484">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.554">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, @@ -981,29 +1175,13 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <dl><dt><span class="strong">Parameters:</span></dt><dd><code>loc</code> - - the destination. Must not be null.</dd><dd><code>action</code> - - the action to add to the multiaction</dd><dd><code>actionsByServer</code> - the multiaction per server</dd><dd><code>nonceGroup</code> - Nonce group.</dd></dl> </li> </ul> -<a name="canTakeOperation(org.apache.hadoop.hbase.HRegionLocation, java.util.Map, java.util.Map)"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>canTakeOperation</h4> -<pre>protected boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.506">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. - We're taking into account the past decision; if we have already accepted - operation on a given region, we accept all operations for this region.</div> -<dl><dt><span class="strong">Parameters:</span></dt><dd><code>loc;</code> - the region and the server name we want to use.</dd> -<dt><span class="strong">Returns:</span></dt><dd>true if this region is considered as busy.</dd></dl> -</li> -</ul> <a name="submitAll(org.apache.hadoop.hbase.TableName, java.util.List, org.apache.hadoop.hbase.client.coprocessor.Batch.Callback, java.lang.Object[])"> <!-- --> </a> <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.569">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.571">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> @@ -1017,7 +1195,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.574">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.576">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, @@ -1030,7 +1208,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.588">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.590">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, @@ -1048,7 +1226,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.615">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.617">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> @@ -1059,7 +1237,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.1726">updateStats</a>(<a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> server, +<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1762">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> @@ -1069,7 +1247,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.1743">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.1779">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, @@ -1086,7 +1264,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.1754">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.1790">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, @@ -1101,7 +1279,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.1765">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.1801">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> @@ -1113,7 +1291,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.1774">createCaller</a>(<a href="../../../../../org/apache/hadoop/hbase/client/CancellableRegionServerCallable.html" title="class in org.apache.hadoop.hbase.client">CancellableRegionServerCallable</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.1810">createCaller</a>(<a href="../../../../../org/apache/hadoop/hbase/client/CancellableRegionServerCallable.html" title="class in org.apache.hadoop.hbase.client">CancellableRegionServerCallable</a> callable)</pre> <div class="block">Create a caller. Isolated to be easily overridden in the tests.</div> </li> </ul> @@ -1123,7 +1301,7 @@ 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.1780">waitUntilDone</a>() +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1816">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> @@ -1135,7 +1313,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>waitForMaximumCurrentTasks</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1785">waitForMaximumCurrentTasks</a>(int max, +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1821">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> @@ -1149,7 +1327,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>waitForMaximumCurrentTasks</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1792">waitForMaximumCurrentTasks</a>(int max, +<pre>void <a href="..
<TRUNCATED>
