http://git-wip-us.apache.org/repos/asf/hbase/blob/a00babbc/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 new file mode 100644 index 0000000..058cfa5 --- /dev/null +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncProcess.html @@ -0,0 +1,1118 @@ +<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd";> +<!-- NewPage --> +<html lang="en"> +<head> +<meta http-equiv="Content-Type" content="text/html" charset="UTF-8"> +<title>AsyncProcess (Apache HBase 2.0.0-SNAPSHOT API)</title> +<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> +</head> +<body> +<script type="text/javascript"><!-- + if (location.href.indexOf('is-external=true') == -1) { + parent.document.title="AsyncProcess (Apache HBase 2.0.0-SNAPSHOT API)"; + } +//--> +</script> +<noscript> +<div>JavaScript is disabled on your browser.</div> +</noscript> +<!-- ========= START OF TOP NAVBAR ======= --> +<div class="topNav"><a name="navbar_top"> +<!-- --> +</a><a href="#skip-navbar_top" title="Skip navigation links"></a><a name="navbar_top_firstrow"> +<!-- --> +</a> +<ul class="navList" title="Navigation"> +<li><a href="../../../../../overview-summary.html">Overview</a></li> +<li><a href="package-summary.html">Package</a></li> +<li class="navBarCell1Rev">Class</li> +<li><a href="class-use/AsyncProcess.html">Use</a></li> +<li><a href="package-tree.html">Tree</a></li> +<li><a href="../../../../../deprecated-list.html">Deprecated</a></li> +<li><a href="../../../../../index-all.html">Index</a></li> +<li><a href="../../../../../help-doc.html">Help</a></li> +</ul> +</div> +<div class="subNav"> +<ul class="navList"> +<li><a href="../../../../../org/apache/hadoop/hbase/client/Append.html" title="class in org.apache.hadoop.hbase.client"><span class="strong">Prev Class</span></a></li> +<li><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client"><span class="strong">Next Class</span></a></li> +</ul> +<ul class="navList"> +<li><a href="../../../../../index.html?org/apache/hadoop/hbase/client/AsyncProcess.html" target="_top">Frames</a></li> +<li><a href="AsyncProcess.html" target="_top">No Frames</a></li> +</ul> +<ul class="navList" id="allclasses_navbar_top"> +<li><a href="../../../../../allclasses-noframe.html">All Classes</a></li> +</ul> +<div> +<script type="text/javascript"><!-- + allClassesLink = document.getElementById("allclasses_navbar_top"); + if(window==top) { + allClassesLink.style.display = "block"; + } + else { + allClassesLink.style.display = "none"; + } + //--> +</script> +</div> +<div> +<ul class="subNavList"> +<li>Summary: </li> +<li><a href="#nested_class_summary">Nested</a> | </li> +<li><a href="#field_summary">Field</a> | </li> +<li><a href="#constructor_summary">Constr</a> | </li> +<li><a href="#method_summary">Method</a></li> +</ul> +<ul class="subNavList"> +<li>Detail: </li> +<li><a href="#field_detail">Field</a> | </li> +<li><a href="#constructor_detail">Constr</a> | </li> +<li><a href="#method_detail">Method</a></li> +</ul> +</div> +<a name="skip-navbar_top"> +<!-- --> +</a></div> +<!-- ========= END OF TOP NAVBAR ========= --> +<!-- ======== START OF CLASS DATA ======== --> +<div class="header"> +<div class="subTitle">org.apache.hadoop.hbase.client</div> +<h2 title="Class AsyncProcess" class="title">Class AsyncProcess</h2> +</div> +<div class="contentContainer"> +<ul class="inheritance"> +<li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">java.lang.Object</a></li> +<li> +<ul class="inheritance"> +<li>org.apache.hadoop.hbase.client.AsyncProcess</li> +</ul> +</li> +</ul> +<div class="description"> +<ul class="blockList"> +<li class="blockList"> +<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.98">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. + <p> + The caller sends a buffer of operation, by calling submit. This class extract from this list + the operations it can send, i.e. the operations that are on region that are not considered + as busy. The process is asynchronous, i.e. it returns immediately when if has finished to + iterate on the list. If, and only if, the maximum number of current task is reached, the call + to submit will block. Alternatively, the caller can call submitAll, in which case all the + operations will be sent. Each call to submit returns a future-like object that can be used + to track operation progress. + </p> + <p> + The class manages internally the retries. + </p> + <p> + The class can be constructed in regular mode, or "global error" mode. In global error mode, + AP tracks errors across all calls (each "future" also has global view of all errors). That + mode is necessary for backward compat with HTable behavior, where multiple submissions are + made and the errors can propagate using any put/flush call, from previous calls. + In "regular" mode, the errors are tracked inside the Future object that is returned. + The results are always tracked inside the Future object and can be retrieved when the call + has finished. Partial results can also be retrieved if some part of multi-request failed. + </p> + <p> + This class is thread safe in regular mode; in global error code, submitting operations and + retrieving errors from different threads may be not thread safe. + Internally, the class is thread safe enough to manage simultaneously new submission and results + arising from older operations. + </p> + <p> + Internally, this class works with <a href="../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client"><code>Row</code></a>, this mean it could be theoretically used for + gets as well. + </p></div> +</li> +</ul> +</div> +<div class="summary"> +<ul class="blockList"> +<li class="blockList"> +<!-- ======== NESTED CLASS SUMMARY ======== --> +<ul class="blockList"> +<li class="blockList"><a name="nested_class_summary"> +<!-- --> +</a> +<h3>Nested Class Summary</h3> +<table class="overviewSummary" border="0" cellpadding="3" cellspacing="0" summary="Nested Class Summary table, listing nested classes, and an explanation"> +<caption><span>Nested Classes</span><span class="tabEnd"> </span></caption> +<tr> +<th class="colFirst" scope="col">Modifier and Type</th> +<th class="colLast" scope="col">Class and Description</th> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>static interface </code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFuture.html" title="interface in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFuture</a></strong></code> +<div class="block">The context used to wait for results from one submit call.</div> +</td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>protected class </code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess.AsyncRequestFutureImpl</a><<a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.AsyncRequestFutureImpl.html" title="type parameter in AsyncProcess.AsyncRequestFutureImpl">CResult</a>></strong></code> +<div class="block">The context, and return value, for a single submit/submitAll call.</div> +</td> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>protected static class </code></td> +<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>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="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> +</table> +</li> +</ul> +<!-- =========== FIELD SUMMARY =========== --> +<ul class="blockList"> +<li class="blockList"><a name="field_summary"> +<!-- --> +</a> +<h3>Field Summary</h3> +<table class="overviewSummary" border="0" cellpadding="3" cellspacing="0" summary="Field Summary table, listing fields, and an explanation"> +<caption><span>Fields</span><span class="tabEnd"> </span></caption> +<tr> +<th class="colFirst" scope="col">Modifier and Type</th> +<th class="colLast" scope="col">Field and Description</th> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>protected <a href="../../../../../org/apache/hadoop/hbase/client/ClusterConnection.html" title="interface in org.apache.hadoop.hbase.client">ClusterConnection</a></code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#connection">connection</a></strong></code> </td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>protected static <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#COUNTER">COUNTER</a></strong></code> </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> +<tr class="rowColor"> +<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"> +<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"> +<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"> +<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"> +<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"> +<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"> +<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"> +<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"> +<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"> +<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"> +<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"> +<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"> +<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"> +<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"> +<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"> +<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"> +<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"> +<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"> +<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"> +<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="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> +</tr> +</table> +</li> +</ul> +<!-- ======== CONSTRUCTOR SUMMARY ======== --> +<ul class="blockList"> +<li class="blockList"><a name="constructor_summary"> +<!-- --> +</a> +<h3>Constructor Summary</h3> +<table class="overviewSummary" border="0" cellpadding="3" cellspacing="0" summary="Constructor Summary table, listing constructors, and an explanation"> +<caption><span>Constructors</span><span class="tabEnd"> </span></caption> +<tr> +<th class="colOne" scope="col">Constructor and Description</th> +</tr> +<tr class="altColor"> +<td class="colOne"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#AsyncProcess(org.apache.hadoop.hbase.client.ClusterConnection,%20org.apache.hadoop.conf.Configuration,%20java.util.concurrent.ExecutorService,%20org.apache.hadoop.hbase.client.RpcRetryingCallerFactory,%20boolean,%20org.apache.hadoop.hbase.ipc.RpcControllerFactory)">AsyncProcess</a></strong>(<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, + boolean useGlobalErrors, + <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcControllerFactory.html" title="class in org.apache.hadoop.hbase.ipc">RpcControllerFactory</a> rpcFactory)</code> </td> +</tr> +</table> +</li> +</ul> +<!-- ========== METHOD SUMMARY =========== --> +<ul class="blockList"> +<li class="blockList"><a name="method_summary"> +<!-- --> +</a> +<h3>Method Summary</h3> +<table class="overviewSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation"> +<caption><span>Methods</span><span class="tabEnd"> </span></caption> +<tr> +<th class="colFirst" scope="col">Modifier and Type</th> +<th class="colLast" scope="col">Method and Description</th> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>private static void</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#addAction(org.apache.hadoop.hbase.ServerName,%20byte[],%20org.apache.hadoop.hbase.client.Action,%20java.util.Map,%20long)">addAction</a></strong>(<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, + long nonceGroup)</code> +<div class="block">Helper that is used when grouping the actions per region server.</div> +</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="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</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, + 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, + <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, + boolean needResults)</code> </td> +</tr> +<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, + <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)</code> +<div class="block">Create a callable.</div> +</td> +</tr> +<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.MultiServerCallable)">createCaller</a></strong>(<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>> callable)</code> +<div class="block">Create a caller.</div> +</td> +</tr> +<tr class="rowColor"> +<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> +<div class="block">Creates the server error tracker to use inside process.</div> +</td> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>protected void</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#decTaskCounters(java.util.Collection,%20org.apache.hadoop.hbase.ServerName)">decTaskCounters</a></strong>(<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)</code> +<div class="block">Decrements the counters for a given region and the region server.</div> +</td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>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></code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#getPool(java.util.concurrent.ExecutorService)">getPool</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)</code> </td> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>boolean</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#hasError()">hasError</a></strong>()</code> +<div class="block">Only used w/useGlobalErrors ctor argument, for HTable backward compat.</div> +</td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>protected void</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html#incTaskCounters(java.util.Collection,%20org.apache.hadoop.hbase.ServerName)">incTaskCounters</a></strong>(<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)</code> +<div class="block">increment the tasks counters for a given set of regions.</div> +</td> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>private static boolean</code></td> +<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="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="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, + <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)</code> +<div class="block">Extract from the rows list what we can submit.</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,%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, + <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,%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="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, + <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)</code> +<div class="block">Submit immediately the list of rows, whatever the server status.</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#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, + <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> +<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"> +<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, + 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, + <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, + <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="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a>> locationErrors, + <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="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>> locationErrorRows, + <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"> +<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> +<div class="block">Only used w/useGlobalErrors ctor argument, for HTable backward compat.</div> +</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#waitForMaximumCurrentTasks(int)">waitForMaximumCurrentTasks</a></strong>(int max)</code> +<div class="block">Wait until the async does not have more than max tasks in progress.</div> +</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> +</table> +<ul class="blockList"> +<li class="blockList"><a name="methods_inherited_from_class_java.lang.Object"> +<!-- --> +</a> +<h3>Methods inherited from class java.lang.<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></h3> +<code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#clone()" title="class or interface in java.lang">clone</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#equals(java.lang.Object)" title="class or interface in java.lang">equals</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#finalize()" title="class or interface in java.lang">finalize</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#getClass()" title="class or interface in java.lang">getClass</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#hashCode()" title="class or interface in java.lang">hashCode</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notify()" title="class or interface in java.lang">notify</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang /Object.html?is-external=true#notifyAll()" title="class or interface in java.lang">notifyAll</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#toString()" title="class or interface in java.lang">toString</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait()" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait(long)" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait(long,%20int)" title="class or interface in java.lang">wait</a></code></li> +</ul> +</li> +</ul> +</li> +</ul> +</div> +<div class="details"> +<ul class="blockList"> +<li class="blockList"> +<!-- ============ FIELD DETAIL =========== --> +<ul class="blockList"> +<li class="blockList"><a name="field_detail"> +<!-- --> +</a> +<h3>Field Detail</h3> +<a name="LOG"> +<!-- --> +</a> +<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.99">LOG</a></pre> +</li> +</ul> +<a name="COUNTER"> +<!-- --> +</a> +<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.100">COUNTER</a></pre> +</li> +</ul> +<a name="PRIMARY_CALL_TIMEOUT_KEY"> +<!-- --> +</a> +<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.102">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> +<a name="START_LOG_ERRORS_AFTER_COUNT_KEY"> +<!-- --> +</a> +<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.110">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 + this stage.</div> +<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.client.AsyncProcess.START_LOG_ERRORS_AFTER_COUNT_KEY">Constant Field Values</a></dd></dl> +</li> +</ul> +<a name="DEFAULT_START_LOG_ERRORS_AFTER_COUNT"> +<!-- --> +</a> +<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.112">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> +<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.130">NO_REQS_RESULT</a></pre> +<div class="block">Return value from a submit that didn't contain any requests.</div> +</li> +</ul> +<a name="id"> +<!-- --> +</a> +<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.167">id</a></pre> +</li> +</ul> +<a name="connection"> +<!-- --> +</a> +<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.169">connection</a></pre> +</li> +</ul> +<a name="rpcCallerFactory"> +<!-- --> +</a> +<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.170">rpcCallerFactory</a></pre> +</li> +</ul> +<a name="rpcFactory"> +<!-- --> +</a> +<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.171">rpcFactory</a></pre> +</li> +</ul> +<a name="globalErrors"> +<!-- --> +</a> +<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.172">globalErrors</a></pre> +</li> +</ul> +<a name="pool"> +<!-- --> +</a> +<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.173">pool</a></pre> +</li> +</ul> +<a name="tasksInProgress"> +<!-- --> +</a> +<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.175">tasksInProgress</a></pre> +</li> +</ul> +<a name="taskCounterPerRegion"> +<!-- --> +</a> +<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.176">taskCounterPerRegion</a></pre> +</li> +</ul> +<a name="taskCounterPerServer"> +<!-- --> +</a> +<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.178">taskCounterPerServer</a></pre> +</li> +</ul> +<a name="startLogErrorsCnt"> +<!-- --> +</a> +<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.182">startLogErrorsCnt</a></pre> +</li> +</ul> +<a name="maxTotalConcurrentTasks"> +<!-- --> +</a> +<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.187">maxTotalConcurrentTasks</a></pre> +<div class="block">The number of tasks simultaneously executed on the cluster.</div> +</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.195">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 + the pressure we put on the region server.</div> +</li> +</ul> +<a name="maxConcurrentTasksPerServer"> +<!-- --> +</a> +<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.200">maxConcurrentTasksPerServer</a></pre> +<div class="block">The number of task simultaneously executed on a single region server.</div> +</li> +</ul> +<a name="pause"> +<!-- --> +</a> +<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.201">pause</a></pre> +</li> +</ul> +<a name="numTries"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>numTries</h4> +<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.202">numTries</a></pre> +</li> +</ul> +<a name="serverTrackerTimeout"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>serverTrackerTimeout</h4> +<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.203">serverTrackerTimeout</a></pre> +</li> +</ul> +<a name="timeout"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>timeout</h4> +<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.204">timeout</a></pre> +</li> +</ul> +<a name="primaryCallTimeoutMicroseconds"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>primaryCallTimeoutMicroseconds</h4> +<pre>protected long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.205">primaryCallTimeoutMicroseconds</a></pre> +</li> +</ul> +</li> +</ul> +<!-- ========= CONSTRUCTOR DETAIL ======== --> +<ul class="blockList"> +<li class="blockList"><a name="constructor_detail"> +<!-- --> +</a> +<h3>Constructor Detail</h3> +<a name="AsyncProcess(org.apache.hadoop.hbase.client.ClusterConnection, org.apache.hadoop.conf.Configuration, java.util.concurrent.ExecutorService, org.apache.hadoop.hbase.client.RpcRetryingCallerFactory, boolean, org.apache.hadoop.hbase.ipc.RpcControllerFactory)"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>AsyncProcess</h4> +<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.246">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, + boolean useGlobalErrors, + <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcControllerFactory.html" title="class in org.apache.hadoop.hbase.ipc">RpcControllerFactory</a> rpcFactory)</pre> +</li> +</ul> +</li> +</ul> +<!-- ============ METHOD DETAIL ========== --> +<ul class="blockList"> +<li class="blockList"><a name="method_detail"> +<!-- --> +</a> +<h3>Method Detail</h3> +<a name="getPool(java.util.concurrent.ExecutorService)"> +<!-- --> +</a> +<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.310">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> +</ul> +<a name="submit(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.320">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, + 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,%20java.util.List,%20boolean,%20org.apache.hadoop.hbase.client.coprocessor.Batch.Callback,%20boolean)"><code>submit(ExecutorService, TableName, List, 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.338">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">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> +<dl><dt><span class="strong">Parameters:</span></dt><dd><code>pool</code> - ExecutorService to use.</dd><dd><code>tableName</code> - The table for which this request is needed.</dd><dd><code>callback</code> - Batch callback. Only called on success (94 behavior).</dd><dd><code>needResults</code> - Whether results are needed, or can be discarded.</dd><dd><code>rows</code> - - the submitted row. Modified by the method: we remove the rows we took.</dd><dd><code>atLeastOne</code> - true if we should submit at least a subset.</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> +</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.410">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, + <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, + <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="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a>> locationErrors, + <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="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>> locationErrorRows, + <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)</pre> +</li> +</ul> +<a name="addAction(org.apache.hadoop.hbase.ServerName, byte[], org.apache.hadoop.hbase.client.Action, java.util.Map, long)"> +<!-- --> +</a> +<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.438">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, + long nonceGroup)</pre> +<div class="block">Helper that is used when grouping the actions per region server.</div> +<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.460">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="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</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.523">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> +<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>. + Uses default ExecutorService for this AP (must have been created with one).</div> +</li> +</ul> +<a name="submitAll(java.util.concurrent.ExecutorService, 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.538">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, + <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> +<div class="block">Submit immediately the list of rows, whatever the server status. Kept for backward + compatibility: it allows to be used with the batch interface that return an array of objects.</div> +<dl><dt><span class="strong">Parameters:</span></dt><dd><code>pool</code> - ExecutorService to use.</dd><dd><code>tableName</code> - name of the table for which the submission is made.</dd><dd><code>rows</code> - the list of rows.</dd><dd><code>callback</code> - the callback.</dd><dd><code>results</code> - Optional array to return the results thru; backward compat.</dd></dl> +</li> +</ul> +<a name="setNonce(org.apache.hadoop.hbase.client.NonceGenerator, org.apache.hadoop.hbase.client.Row, org.apache.hadoop.hbase.client.Action)"> +<!-- --> +</a> +<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.563">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> +</ul> +<a name="createAsyncRequestFuture(org.apache.hadoop.hbase.TableName, java.util.List, long, java.util.concurrent.ExecutorService, org.apache.hadoop.hbase.client.coprocessor.Batch.Callback, java.lang.Object[], boolean)"> +<!-- --> +</a> +<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.1615">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, + <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, + boolean needResults)</pre> +</li> +</ul> +<a name="createCallable(org.apache.hadoop.hbase.ServerName, org.apache.hadoop.hbase.TableName, org.apache.hadoop.hbase.client.MultiAction)"> +<!-- --> +</a> +<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.1626">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> +</li> +</ul> +<a name="createCaller(org.apache.hadoop.hbase.client.MultiServerCallable)"> +<!-- --> +</a> +<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.1635">createCaller</a>(<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>> callable)</pre> +<div class="block">Create a caller. Isolated to be easily overridden in the tests.</div> +</li> +</ul> +<a name="waitUntilDone()"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>waitUntilDone</h4> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1641">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> +<ul class="blockList"> +<li class="blockList"> +<h4>waitForMaximumCurrentTasks</h4> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1646">waitForMaximumCurrentTasks</a>(int max) + 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="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.1676">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> +</li> +</ul> +<a name="waitForAllPreviousOpsAndReset(java.util.List)"> +<!-- --> +</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.1689">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) + 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> + 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> +</li> +</ul> +<a name="incTaskCounters(java.util.Collection, org.apache.hadoop.hbase.ServerName)"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>incTaskCounters</h4> +<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1706">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> +</ul> +<a name="decTaskCounters(java.util.Collection, org.apache.hadoop.hbase.ServerName)"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>decTaskCounters</h4> +<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncProcess.html#line.1732">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
<TRUNCATED>
