| <!DOCTYPE HTML> |
| <html lang="en"> |
| <head> |
| <!-- Generated by javadoc (17) --> |
| <title>AsyncBatchRpcRetryingCaller (Apache HBase 4.0.0-alpha-1-SNAPSHOT API)</title> |
| <meta name="viewport" content="width=device-width, initial-scale=1"> |
| <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> |
| <meta name="description" content="declaration: package: org.apache.hadoop.hbase.client, class: AsyncBatchRpcRetryingCaller"> |
| <meta name="generator" content="javadoc/ClassWriterImpl"> |
| <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> |
| <link rel="stylesheet" type="text/css" href="../../../../../script-dir/jquery-ui.min.css" title="Style"> |
| <link rel="stylesheet" type="text/css" href="../../../../../jquery-ui.overrides.css" title="Style"> |
| <script type="text/javascript" src="../../../../../script.js"></script> |
| <script type="text/javascript" src="../../../../../script-dir/jquery-3.6.1.min.js"></script> |
| <script type="text/javascript" src="../../../../../script-dir/jquery-ui.min.js"></script> |
| </head> |
| <body class="class-declaration-page"> |
| <script type="text/javascript">var evenRowColor = "even-row-color"; |
| var oddRowColor = "odd-row-color"; |
| var tableTab = "table-tab"; |
| var activeTableTab = "active-table-tab"; |
| var pathtoroot = "../../../../../"; |
| loadScripts(document, 'script');</script> |
| <noscript> |
| <div>JavaScript is disabled on your browser.</div> |
| </noscript> |
| <div class="flex-box"> |
| <header role="banner" class="flex-header"> |
| <nav role="navigation"> |
| <!-- ========= START OF TOP NAVBAR ======= --> |
| <div class="top-nav" id="navbar-top"> |
| <div class="skip-nav"><a href="#skip-navbar-top" title="Skip navigation links">Skip navigation links</a></div> |
| <ul id="navbar-top-firstrow" class="nav-list" title="Navigation"> |
| <li><a href="../../../../../index.html">Overview</a></li> |
| <li><a href="package-summary.html">Package</a></li> |
| <li class="nav-bar-cell1-rev">Class</li> |
| <li><a href="class-use/AsyncBatchRpcRetryingCaller.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#class">Help</a></li> |
| </ul> |
| </div> |
| <div class="sub-nav"> |
| <div> |
| <ul class="sub-nav-list"> |
| <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="sub-nav-list"> |
| <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> |
| <div class="nav-list-search"><label for="search-input">SEARCH:</label> |
| <input type="text" id="search-input" value="search" disabled="disabled"> |
| <input type="reset" id="reset-button" value="reset" disabled="disabled"> |
| </div> |
| </div> |
| <!-- ========= END OF TOP NAVBAR ========= --> |
| <span class="skip-nav" id="skip-navbar-top"></span></nav> |
| </header> |
| <div class="flex-content"> |
| <main role="main"> |
| <!-- ======== START OF CLASS DATA ======== --> |
| <div class="header"> |
| <div class="sub-title"><span class="package-label-in-type">Package</span> <a href="package-summary.html">org.apache.hadoop.hbase.client</a></div> |
| <h1 title="Class AsyncBatchRpcRetryingCaller" class="title">Class AsyncBatchRpcRetryingCaller<T></h1> |
| </div> |
| <div class="inheritance" title="Inheritance Tree"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html" title="class or interface in java.lang" class="external-link">java.lang.Object</a> |
| <div class="inheritance">org.apache.hadoop.hbase.client.AsyncBatchRpcRetryingCaller<T></div> |
| </div> |
| <section class="class-description" id="class-description"> |
| <hr> |
| <div class="type-signature"><span class="annotations">@Private |
| </span><span class="modifiers">class </span><span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-86">AsyncBatchRpcRetryingCaller</a><T></span> |
| <span class="extends-implements">extends <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html" title="class or interface in java.lang" class="external-link">Object</a></span></div> |
| <div class="block">Retry caller for batch. |
| <p> |
| Notice that, the <a href="#operationTimeoutNs"><code>operationTimeoutNs</code></a> is the total time limit now which is the same with |
| other single operations |
| <p> |
| And the <a href="#maxAttempts"><code>maxAttempts</code></a> is a limit for each single operation in the batch logically. In the |
| implementation, we will record a <code>tries</code> parameter for each operation group, and if it is |
| split to several groups when retrying, the sub groups will inherit the <code>tries</code>. You can |
| imagine that the whole retrying process is a tree, and the <a href="#maxAttempts"><code>maxAttempts</code></a> is the limit of |
| the depth of the tree.</div> |
| </section> |
| <section class="summary"> |
| <ul class="summary-list"> |
| <!-- ======== NESTED CLASS SUMMARY ======== --> |
| <li> |
| <section class="nested-class-summary" id="nested-class-summary"> |
| <h2>Nested Class Summary</h2> |
| <div class="caption"><span>Nested Classes</span></div> |
| <div class="summary-table three-column-summary"> |
| <div class="table-header col-first">Modifier and Type</div> |
| <div class="table-header col-second">Class</div> |
| <div class="table-header col-last">Description</div> |
| <div class="col-first even-row-color"><code>private static final class </code></div> |
| <div class="col-second even-row-color"><code><a href="AsyncBatchRpcRetryingCaller.RegionRequest.html" class="type-name-link" title="class in org.apache.hadoop.hbase.client">AsyncBatchRpcRetryingCaller.RegionRequest</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>private static final class </code></div> |
| <div class="col-second odd-row-color"><code><a href="AsyncBatchRpcRetryingCaller.ServerRequest.html" class="type-name-link" title="class in org.apache.hadoop.hbase.client">AsyncBatchRpcRetryingCaller.ServerRequest</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| </div> |
| </section> |
| </li> |
| <!-- =========== FIELD SUMMARY =========== --> |
| <li> |
| <section class="field-summary" id="field-summary"> |
| <h2>Field Summary</h2> |
| <div class="caption"><span>Fields</span></div> |
| <div class="summary-table three-column-summary"> |
| <div class="table-header col-first">Modifier and Type</div> |
| <div class="table-header col-second">Field</div> |
| <div class="table-header col-last">Description</div> |
| <div class="col-first even-row-color"><code>private final <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/IdentityHashMap.html" title="class or interface in java.util" class="external-link">IdentityHashMap</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>,<wbr><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><<a href="RetriesExhaustedException.ThrowableWithExtraContext.html" title="class in org.apache.hadoop.hbase.client">RetriesExhaustedException.ThrowableWithExtraContext</a>>></code></div> |
| <div class="col-second even-row-color"><code><a href="#action2Errors" class="member-name-link">action2Errors</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>private final <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/IdentityHashMap.html" title="class or interface in java.util" class="external-link">IdentityHashMap</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>,<wbr><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/concurrent/CompletableFuture.html" title="class or interface in java.util.concurrent" class="external-link">CompletableFuture</a><<a href="AsyncBatchRpcRetryingCaller.html" title="type parameter in AsyncBatchRpcRetryingCaller">T</a>>></code></div> |
| <div class="col-second odd-row-color"><code><a href="#action2Future" class="member-name-link">action2Future</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>private final <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>></code></div> |
| <div class="col-second even-row-color"><code><a href="#actions" class="member-name-link">actions</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>private final <a href="AsyncConnectionImpl.html" title="class in org.apache.hadoop.hbase.client">AsyncConnectionImpl</a></code></div> |
| <div class="col-second odd-row-color"><code><a href="#conn" class="member-name-link">conn</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>private final <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/concurrent/CompletableFuture.html" title="class or interface in java.util.concurrent" class="external-link">CompletableFuture</a><<a href="AsyncBatchRpcRetryingCaller.html" title="type parameter in AsyncBatchRpcRetryingCaller">T</a>>></code></div> |
| <div class="col-second even-row-color"><code><a href="#futures" class="member-name-link">futures</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>private static final org.slf4j.Logger</code></div> |
| <div class="col-second odd-row-color"><code><a href="#LOG" class="member-name-link">LOG</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>private final int</code></div> |
| <div class="col-second even-row-color"><code><a href="#maxAttempts" class="member-name-link">maxAttempts</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>private final long</code></div> |
| <div class="col-second odd-row-color"><code><a href="#operationTimeoutNs" class="member-name-link">operationTimeoutNs</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>private final <a href="backoff/HBaseServerExceptionPauseManager.html" title="class in org.apache.hadoop.hbase.client.backoff">HBaseServerExceptionPauseManager</a></code></div> |
| <div class="col-second even-row-color"><code><a href="#pauseManager" class="member-name-link">pauseManager</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>private final <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a>,<wbr>byte[]></code></div> |
| <div class="col-second odd-row-color"><code><a href="#requestAttributes" class="member-name-link">requestAttributes</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>private final org.apache.hbase.thirdparty.io.netty.util.Timer</code></div> |
| <div class="col-second even-row-color"><code><a href="#retryTimer" class="member-name-link">retryTimer</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>private final long</code></div> |
| <div class="col-second odd-row-color"><code><a href="#rpcTimeoutNs" class="member-name-link">rpcTimeoutNs</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>private final int</code></div> |
| <div class="col-second even-row-color"><code><a href="#startLogErrorsCnt" class="member-name-link">startLogErrorsCnt</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>private final long</code></div> |
| <div class="col-second odd-row-color"><code><a href="#startNs" class="member-name-link">startNs</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>private final <a href="../TableName.html" title="class in org.apache.hadoop.hbase">TableName</a></code></div> |
| <div class="col-second even-row-color"><code><a href="#tableName" class="member-name-link">tableName</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| </div> |
| </section> |
| </li> |
| <!-- ======== CONSTRUCTOR SUMMARY ======== --> |
| <li> |
| <section class="constructor-summary" id="constructor-summary"> |
| <h2>Constructor Summary</h2> |
| <div class="caption"><span>Constructors</span></div> |
| <div class="summary-table two-column-summary"> |
| <div class="table-header col-first">Constructor</div> |
| <div class="table-header col-last">Description</div> |
| <div class="col-constructor-name even-row-color"><code><a href="#%3Cinit%3E(org.apache.hbase.thirdparty.io.netty.util.Timer,org.apache.hadoop.hbase.client.AsyncConnectionImpl,org.apache.hadoop.hbase.TableName,java.util.List,long,long,int,long,long,int,java.util.Map)" class="member-name-link">AsyncBatchRpcRetryingCaller</a><wbr>(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, |
| <a href="AsyncConnectionImpl.html" title="class in org.apache.hadoop.hbase.client">AsyncConnectionImpl</a> conn, |
| <a href="../TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><? extends <a href="Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> actions, |
| long pauseNs, |
| long pauseNsForServerOverloaded, |
| int maxAttempts, |
| long operationTimeoutNs, |
| long rpcTimeoutNs, |
| int startLogErrorsCnt, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a>,<wbr>byte[]> requestAttributes)</code></div> |
| <div class="col-last even-row-color"> </div> |
| </div> |
| </section> |
| </li> |
| <!-- ========== METHOD SUMMARY =========== --> |
| <li> |
| <section class="method-summary" id="method-summary"> |
| <h2>Method Summary</h2> |
| <div id="method-summary-table"> |
| <div class="table-tabs" role="tablist" aria-orientation="horizontal"><button id="method-summary-table-tab0" role="tab" aria-selected="true" aria-controls="method-summary-table.tabpanel" tabindex="0" onkeydown="switchTab(event)" onclick="show('method-summary-table', 'method-summary-table', 3)" class="active-table-tab">All Methods</button><button id="method-summary-table-tab1" role="tab" aria-selected="false" aria-controls="method-summary-table.tabpanel" tabindex="-1" onkeydown="switchTab(event)" onclick="show('method-summary-table', 'method-summary-table-tab1', 3)" class="table-tab">Static Methods</button><button id="method-summary-table-tab2" role="tab" aria-selected="false" aria-controls="method-summary-table.tabpanel" tabindex="-1" onkeydown="switchTab(event)" onclick="show('method-summary-table', 'method-summary-table-tab2', 3)" class="table-tab">Instance Methods</button><button id="method-summary-table-tab4" role="tab" aria-selected="false" aria-controls="method-summary-table.tabpanel" tabindex="-1" onkeydown="switchTab(event)" onclick="show('method-summary-table', 'method-summary-table-tab4', 3)" class="table-tab">Concrete Methods</button></div> |
| <div id="method-summary-table.tabpanel" role="tabpanel"> |
| <div class="summary-table three-column-summary" aria-labelledby="method-summary-table-tab0"> |
| <div class="table-header col-first">Modifier and Type</div> |
| <div class="table-header col-second">Method</div> |
| <div class="table-header col-last">Description</div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>private void</code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#addError(java.lang.Iterable,java.lang.Throwable,org.apache.hadoop.hbase.ServerName)" class="member-name-link">addError</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Iterable.html" title="class or interface in java.lang" class="external-link">Iterable</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>> actions, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Throwable.html" title="class or interface in java.lang" class="external-link">Throwable</a> error, |
| <a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName)</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>private void</code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#addError(org.apache.hadoop.hbase.client.Action,java.lang.Throwable,org.apache.hadoop.hbase.ServerName)" class="member-name-link">addError</a><wbr>(<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a> action, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Throwable.html" title="class or interface in java.lang" class="external-link">Throwable</a> error, |
| <a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName)</code></div> |
| <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiRequest</code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#buildReq(java.util.Map,java.util.List,java.util.Map)" class="member-name-link">buildReq</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><byte[],<wbr><a href="AsyncBatchRpcRetryingCaller.RegionRequest.html" title="class in org.apache.hadoop.hbase.client">AsyncBatchRpcRetryingCaller.RegionRequest</a>> actionsByRegion, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><<a href="../ExtendedCellScannable.html" title="interface in org.apache.hadoop.hbase">ExtendedCellScannable</a>> cells, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Integer.html" title="class or interface in java.lang" class="external-link">Integer</a>,<wbr><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Integer.html" title="class or interface in java.lang" class="external-link">Integer</a>> indexMap)</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/concurrent/CompletableFuture.html" title="class or interface in java.util.concurrent" class="external-link">CompletableFuture</a><<a href="AsyncBatchRpcRetryingCaller.html" title="type parameter in AsyncBatchRpcRetryingCaller">T</a>>></code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#call()" class="member-name-link">call</a>()</code></div> |
| <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>private void</code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#failAll(java.util.stream.Stream,int)" class="member-name-link">failAll</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/stream/Stream.html" title="class or interface in java.util.stream" class="external-link">Stream</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>> actions, |
| int tries)</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>private void</code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#failAll(java.util.stream.Stream,int,java.lang.Throwable,org.apache.hadoop.hbase.ServerName)" class="member-name-link">failAll</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/stream/Stream.html" title="class or interface in java.util.stream" class="external-link">Stream</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>> actions, |
| int tries, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Throwable.html" title="class or interface in java.lang" class="external-link">Throwable</a> error, |
| <a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName)</code></div> |
| <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>private void</code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#failOne(org.apache.hadoop.hbase.client.Action,int,java.lang.Throwable,long,java.lang.String)" class="member-name-link">failOne</a><wbr>(<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a> action, |
| int tries, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Throwable.html" title="class or interface in java.lang" class="external-link">Throwable</a> error, |
| long currentTime, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a> extras)</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>private <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a></code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#getExtraContextForError(org.apache.hadoop.hbase.ServerName)" class="member-name-link">getExtraContextForError</a><wbr>(<a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName)</code></div> |
| <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>private void</code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#groupAndSend(java.util.stream.Stream,int)" class="member-name-link">groupAndSend</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/stream/Stream.html" title="class or interface in java.util.stream" class="external-link">Stream</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>> actions, |
| int tries)</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first odd-row-color method-summary-table method-summary-table-tab1 method-summary-table-tab4"><code>private static boolean</code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab1 method-summary-table-tab4"><code><a href="#hasIncrementOrAppend(org.apache.hadoop.hbase.client.Row)" class="member-name-link">hasIncrementOrAppend</a><wbr>(<a href="Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a> action)</code></div> |
| <div class="col-last odd-row-color method-summary-table method-summary-table-tab1 method-summary-table-tab4"> </div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab1 method-summary-table-tab4"><code>private static boolean</code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab1 method-summary-table-tab4"><code><a href="#hasIncrementOrAppend(org.apache.hadoop.hbase.client.RowMutations)" class="member-name-link">hasIncrementOrAppend</a><wbr>(<a href="RowMutations.html" title="class in org.apache.hadoop.hbase.client">RowMutations</a> mutations)</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab1 method-summary-table-tab4"> </div> |
| <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>private void</code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#logException(int,java.util.function.Supplier,java.lang.Throwable,org.apache.hadoop.hbase.ServerName)" class="member-name-link">logException</a><wbr>(int tries, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/function/Supplier.html" title="class or interface in java.util.function" class="external-link">Supplier</a><<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/stream/Stream.html" title="class or interface in java.util.stream" class="external-link">Stream</a><<a href="AsyncBatchRpcRetryingCaller.RegionRequest.html" title="class in org.apache.hadoop.hbase.client">AsyncBatchRpcRetryingCaller.RegionRequest</a>>> regionsSupplier, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Throwable.html" title="class or interface in java.lang" class="external-link">Throwable</a> error, |
| <a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName)</code></div> |
| <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>private void</code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#onComplete(java.util.Map,int,org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.client.MultiResponse)" class="member-name-link">onComplete</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><byte[],<wbr><a href="AsyncBatchRpcRetryingCaller.RegionRequest.html" title="class in org.apache.hadoop.hbase.client">AsyncBatchRpcRetryingCaller.RegionRequest</a>> actionsByRegion, |
| int tries, |
| <a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName, |
| <a href="MultiResponse.html" title="class in org.apache.hadoop.hbase.client">MultiResponse</a> resp)</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>private void</code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#onComplete(org.apache.hadoop.hbase.client.Action,org.apache.hadoop.hbase.client.AsyncBatchRpcRetryingCaller.RegionRequest,int,org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.client.MultiResponse.RegionResult,java.util.List,java.lang.Throwable,org.apache.commons.lang3.mutable.MutableBoolean)" class="member-name-link">onComplete</a><wbr>(<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a> action, |
| <a href="AsyncBatchRpcRetryingCaller.RegionRequest.html" title="class in org.apache.hadoop.hbase.client">AsyncBatchRpcRetryingCaller.RegionRequest</a> regionReq, |
| int tries, |
| <a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName, |
| <a href="MultiResponse.RegionResult.html" title="class in org.apache.hadoop.hbase.client">MultiResponse.RegionResult</a> regionResult, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>> failedActions, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Throwable.html" title="class or interface in java.lang" class="external-link">Throwable</a> regionException, |
| org.apache.commons.lang3.mutable.MutableBoolean retryImmediately)</code></div> |
| <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>private void</code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#onError(java.util.Map,int,java.lang.Throwable,org.apache.hadoop.hbase.ServerName)" class="member-name-link">onError</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><byte[],<wbr><a href="AsyncBatchRpcRetryingCaller.RegionRequest.html" title="class in org.apache.hadoop.hbase.client">AsyncBatchRpcRetryingCaller.RegionRequest</a>> actionsByRegion, |
| int tries, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Throwable.html" title="class or interface in java.lang" class="external-link">Throwable</a> t, |
| <a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName)</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>private <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><<a href="RetriesExhaustedException.ThrowableWithExtraContext.html" title="class in org.apache.hadoop.hbase.client">RetriesExhaustedException.ThrowableWithExtraContext</a>></code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#removeErrors(org.apache.hadoop.hbase.client.Action)" class="member-name-link">removeErrors</a><wbr>(<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a> action)</code></div> |
| <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>private void</code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#sendOrDelay(java.util.Map,int)" class="member-name-link">sendOrDelay</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><<a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a>,<wbr><a href="AsyncBatchRpcRetryingCaller.ServerRequest.html" title="class in org.apache.hadoop.hbase.client">AsyncBatchRpcRetryingCaller.ServerRequest</a>> actionsByServer, |
| int tries)</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>private void</code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#sendToServer(org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.client.AsyncBatchRpcRetryingCaller.ServerRequest,int)" class="member-name-link">sendToServer</a><wbr>(<a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName, |
| <a href="AsyncBatchRpcRetryingCaller.ServerRequest.html" title="class in org.apache.hadoop.hbase.client">AsyncBatchRpcRetryingCaller.ServerRequest</a> serverReq, |
| int tries)</code></div> |
| <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>private void</code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#tryResubmit(java.util.stream.Stream,int,boolean,java.lang.Throwable)" class="member-name-link">tryResubmit</a><wbr>(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/stream/Stream.html" title="class or interface in java.util.stream" class="external-link">Stream</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>> actions, |
| int tries, |
| boolean immediately, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Throwable.html" title="class or interface in java.lang" class="external-link">Throwable</a> error)</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| </div> |
| </div> |
| </div> |
| <div class="inherited-list"> |
| <h3 id="methods-inherited-from-class-java.lang.Object">Methods inherited from class java.lang.<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html" title="class or interface in java.lang" class="external-link">Object</a></h3> |
| <code><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#clone()" title="class or interface in java.lang" class="external-link">clone</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#equals(java.lang.Object)" title="class or interface in java.lang" class="external-link">equals</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#finalize()" title="class or interface in java.lang" class="external-link">finalize</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#getClass()" title="class or interface in java.lang" class="external-link">getClass</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#hashCode()" title="class or interface in java.lang" class="external-link">hashCode</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#notify()" title="class or interface in java.lang" class="external-link">notify</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#notifyAll()" title="class or interface in java.lang" class="external-link">notifyAll</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#toString()" title="class or interface in java.lang" class="external-link">toString</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#wait()" title="class or interface in java.lang" class="external-link">wait</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#wait(long)" title="class or interface in java.lang" class="external-link">wait</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#wait(long,int)" title="class or interface in java.lang" class="external-link">wait</a></code></div> |
| </section> |
| </li> |
| </ul> |
| </section> |
| <section class="details"> |
| <ul class="details-list"> |
| <!-- ============ FIELD DETAIL =========== --> |
| <li> |
| <section class="field-details" id="field-detail"> |
| <h2>Field Details</h2> |
| <ul class="member-list"> |
| <li> |
| <section class="detail" id="LOG"> |
| <h3>LOG</h3> |
| <div class="member-signature"><span class="modifiers">private static final</span> <span class="return-type">org.slf4j.Logger</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-89">LOG</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="retryTimer"> |
| <h3>retryTimer</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type">org.apache.hbase.thirdparty.io.netty.util.Timer</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-91">retryTimer</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="conn"> |
| <h3>conn</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type"><a href="AsyncConnectionImpl.html" title="class in org.apache.hadoop.hbase.client">AsyncConnectionImpl</a></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-93">conn</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="tableName"> |
| <h3>tableName</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type"><a href="../TableName.html" title="class in org.apache.hadoop.hbase">TableName</a></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-95">tableName</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="actions"> |
| <h3>actions</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-97">actions</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="futures"> |
| <h3>futures</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/concurrent/CompletableFuture.html" title="class or interface in java.util.concurrent" class="external-link">CompletableFuture</a><<a href="AsyncBatchRpcRetryingCaller.html" title="type parameter in AsyncBatchRpcRetryingCaller">T</a>>></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-99">futures</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="action2Future"> |
| <h3>action2Future</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/IdentityHashMap.html" title="class or interface in java.util" class="external-link">IdentityHashMap</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>,<wbr><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/concurrent/CompletableFuture.html" title="class or interface in java.util.concurrent" class="external-link">CompletableFuture</a><<a href="AsyncBatchRpcRetryingCaller.html" title="type parameter in AsyncBatchRpcRetryingCaller">T</a>>></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-101">action2Future</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="action2Errors"> |
| <h3>action2Errors</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/IdentityHashMap.html" title="class or interface in java.util" class="external-link">IdentityHashMap</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>,<wbr><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><<a href="RetriesExhaustedException.ThrowableWithExtraContext.html" title="class in org.apache.hadoop.hbase.client">RetriesExhaustedException.ThrowableWithExtraContext</a>>></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-103">action2Errors</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="maxAttempts"> |
| <h3>maxAttempts</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type">int</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-105">maxAttempts</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="operationTimeoutNs"> |
| <h3>operationTimeoutNs</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type">long</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-107">operationTimeoutNs</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="rpcTimeoutNs"> |
| <h3>rpcTimeoutNs</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type">long</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-109">rpcTimeoutNs</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="startLogErrorsCnt"> |
| <h3>startLogErrorsCnt</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type">int</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-111">startLogErrorsCnt</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="startNs"> |
| <h3>startNs</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type">long</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-113">startNs</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="pauseManager"> |
| <h3>pauseManager</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type"><a href="backoff/HBaseServerExceptionPauseManager.html" title="class in org.apache.hadoop.hbase.client.backoff">HBaseServerExceptionPauseManager</a></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-115">pauseManager</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="requestAttributes"> |
| <h3>requestAttributes</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a>,<wbr>byte[]></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-117">requestAttributes</a></span></div> |
| </section> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <!-- ========= CONSTRUCTOR DETAIL ======== --> |
| <li> |
| <section class="constructor-details" id="constructor-detail"> |
| <h2>Constructor Details</h2> |
| <ul class="member-list"> |
| <li> |
| <section class="detail" id="<init>(org.apache.hbase.thirdparty.io.netty.util.Timer,org.apache.hadoop.hbase.client.AsyncConnectionImpl,org.apache.hadoop.hbase.TableName,java.util.List,long,long,int,long,long,int,java.util.Map)"> |
| <h3>AsyncBatchRpcRetryingCaller</h3> |
| <div class="member-signature"><span class="modifiers">public</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-152">AsyncBatchRpcRetryingCaller</a></span><wbr><span class="parameters">(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, |
| <a href="AsyncConnectionImpl.html" title="class in org.apache.hadoop.hbase.client">AsyncConnectionImpl</a> conn, |
| <a href="../TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><? extends <a href="Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>> actions, |
| long pauseNs, |
| long pauseNsForServerOverloaded, |
| int maxAttempts, |
| long operationTimeoutNs, |
| long rpcTimeoutNs, |
| int startLogErrorsCnt, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a>,<wbr>byte[]> requestAttributes)</span></div> |
| </section> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <!-- ============ METHOD DETAIL ========== --> |
| <li> |
| <section class="method-details" id="method-detail"> |
| <h2>Method Details</h2> |
| <ul class="member-list"> |
| <li> |
| <section class="detail" id="hasIncrementOrAppend(org.apache.hadoop.hbase.client.Row)"> |
| <h3>hasIncrementOrAppend</h3> |
| <div class="member-signature"><span class="modifiers">private static</span> <span class="return-type">boolean</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-189">hasIncrementOrAppend</a></span><wbr><span class="parameters">(<a href="Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a> action)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="hasIncrementOrAppend(org.apache.hadoop.hbase.client.RowMutations)"> |
| <h3>hasIncrementOrAppend</h3> |
| <div class="member-signature"><span class="modifiers">private static</span> <span class="return-type">boolean</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-200">hasIncrementOrAppend</a></span><wbr><span class="parameters">(<a href="RowMutations.html" title="class in org.apache.hadoop.hbase.client">RowMutations</a> mutations)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="removeErrors(org.apache.hadoop.hbase.client.Action)"> |
| <h3>removeErrors</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><<a href="RetriesExhaustedException.ThrowableWithExtraContext.html" title="class in org.apache.hadoop.hbase.client">RetriesExhaustedException.ThrowableWithExtraContext</a>></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-209">removeErrors</a></span><wbr><span class="parameters">(<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a> action)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="logException(int,java.util.function.Supplier,java.lang.Throwable,org.apache.hadoop.hbase.ServerName)"> |
| <h3>logException</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">void</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-215">logException</a></span><wbr><span class="parameters">(int tries, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/function/Supplier.html" title="class or interface in java.util.function" class="external-link">Supplier</a><<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/stream/Stream.html" title="class or interface in java.util.stream" class="external-link">Stream</a><<a href="AsyncBatchRpcRetryingCaller.RegionRequest.html" title="class in org.apache.hadoop.hbase.client">AsyncBatchRpcRetryingCaller.RegionRequest</a>>> regionsSupplier, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Throwable.html" title="class or interface in java.lang" class="external-link">Throwable</a> error, |
| <a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="getExtraContextForError(org.apache.hadoop.hbase.ServerName)"> |
| <h3>getExtraContextForError</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-226">getExtraContextForError</a></span><wbr><span class="parameters">(<a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="addError(org.apache.hadoop.hbase.client.Action,java.lang.Throwable,org.apache.hadoop.hbase.ServerName)"> |
| <h3>addError</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">void</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-230">addError</a></span><wbr><span class="parameters">(<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a> action, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Throwable.html" title="class or interface in java.lang" class="external-link">Throwable</a> error, |
| <a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="addError(java.lang.Iterable,java.lang.Throwable,org.apache.hadoop.hbase.ServerName)"> |
| <h3>addError</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">void</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-239">addError</a></span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Iterable.html" title="class or interface in java.lang" class="external-link">Iterable</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>> actions, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Throwable.html" title="class or interface in java.lang" class="external-link">Throwable</a> error, |
| <a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="failOne(org.apache.hadoop.hbase.client.Action,int,java.lang.Throwable,long,java.lang.String)"> |
| <h3>failOne</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">void</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-243">failOne</a></span><wbr><span class="parameters">(<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a> action, |
| int tries, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Throwable.html" title="class or interface in java.lang" class="external-link">Throwable</a> error, |
| long currentTime, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a> extras)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="failAll(java.util.stream.Stream,int,java.lang.Throwable,org.apache.hadoop.hbase.ServerName)"> |
| <h3>failAll</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">void</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-259">failAll</a></span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/stream/Stream.html" title="class or interface in java.util.stream" class="external-link">Stream</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>> actions, |
| int tries, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Throwable.html" title="class or interface in java.lang" class="external-link">Throwable</a> error, |
| <a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="failAll(java.util.stream.Stream,int)"> |
| <h3>failAll</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">void</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-265">failAll</a></span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/stream/Stream.html" title="class or interface in java.util.stream" class="external-link">Stream</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>> actions, |
| int tries)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="buildReq(java.util.Map,java.util.List,java.util.Map)"> |
| <h3>buildReq</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiRequest</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-276">buildReq</a></span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><byte[],<wbr><a href="AsyncBatchRpcRetryingCaller.RegionRequest.html" title="class in org.apache.hadoop.hbase.client">AsyncBatchRpcRetryingCaller.RegionRequest</a>> actionsByRegion, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><<a href="../ExtendedCellScannable.html" title="interface in org.apache.hadoop.hbase">ExtendedCellScannable</a>> cells, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Integer.html" title="class or interface in java.lang" class="external-link">Integer</a>,<wbr><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Integer.html" title="class or interface in java.lang" class="external-link">Integer</a>> indexMap)</span> |
| throws <span class="exceptions"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/io/IOException.html" title="class or interface in java.io" class="external-link">IOException</a></span></div> |
| <dl class="notes"> |
| <dt>Throws:</dt> |
| <dd><code><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/io/IOException.html" title="class or interface in java.io" class="external-link">IOException</a></code></dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="onComplete(org.apache.hadoop.hbase.client.Action,org.apache.hadoop.hbase.client.AsyncBatchRpcRetryingCaller.RegionRequest,int,org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.client.MultiResponse.RegionResult,java.util.List,java.lang.Throwable,org.apache.commons.lang3.mutable.MutableBoolean)"> |
| <h3>onComplete</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">void</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-297">onComplete</a></span><wbr><span class="parameters">(<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a> action, |
| <a href="AsyncBatchRpcRetryingCaller.RegionRequest.html" title="class in org.apache.hadoop.hbase.client">AsyncBatchRpcRetryingCaller.RegionRequest</a> regionReq, |
| int tries, |
| <a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName, |
| <a href="MultiResponse.RegionResult.html" title="class in org.apache.hadoop.hbase.client">MultiResponse.RegionResult</a> regionResult, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>> failedActions, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Throwable.html" title="class or interface in java.lang" class="external-link">Throwable</a> regionException, |
| org.apache.commons.lang3.mutable.MutableBoolean retryImmediately)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="onComplete(java.util.Map,int,org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.client.MultiResponse)"> |
| <h3>onComplete</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">void</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-326">onComplete</a></span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><byte[],<wbr><a href="AsyncBatchRpcRetryingCaller.RegionRequest.html" title="class in org.apache.hadoop.hbase.client">AsyncBatchRpcRetryingCaller.RegionRequest</a>> actionsByRegion, |
| int tries, |
| <a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName, |
| <a href="MultiResponse.html" title="class in org.apache.hadoop.hbase.client">MultiResponse</a> resp)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="sendToServer(org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.client.AsyncBatchRpcRetryingCaller.ServerRequest,int)"> |
| <h3>sendToServer</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">void</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-365">sendToServer</a></span><wbr><span class="parameters">(<a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName, |
| <a href="AsyncBatchRpcRetryingCaller.ServerRequest.html" title="class in org.apache.hadoop.hbase.client">AsyncBatchRpcRetryingCaller.ServerRequest</a> serverReq, |
| int tries)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="sendOrDelay(java.util.Map,int)"> |
| <h3>sendOrDelay</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">void</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-420">sendOrDelay</a></span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><<a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a>,<wbr><a href="AsyncBatchRpcRetryingCaller.ServerRequest.html" title="class in org.apache.hadoop.hbase.client">AsyncBatchRpcRetryingCaller.ServerRequest</a>> actionsByServer, |
| int tries)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="onError(java.util.Map,int,java.lang.Throwable,org.apache.hadoop.hbase.ServerName)"> |
| <h3>onError</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">void</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-453">onError</a></span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><byte[],<wbr><a href="AsyncBatchRpcRetryingCaller.RegionRequest.html" title="class in org.apache.hadoop.hbase.client">AsyncBatchRpcRetryingCaller.RegionRequest</a>> actionsByRegion, |
| int tries, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Throwable.html" title="class or interface in java.lang" class="external-link">Throwable</a> t, |
| <a href="../ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> serverName)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="tryResubmit(java.util.stream.Stream,int,boolean,java.lang.Throwable)"> |
| <h3>tryResubmit</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">void</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-470">tryResubmit</a></span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/stream/Stream.html" title="class or interface in java.util.stream" class="external-link">Stream</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>> actions, |
| int tries, |
| boolean immediately, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Throwable.html" title="class or interface in java.lang" class="external-link">Throwable</a> error)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="groupAndSend(java.util.stream.Stream,int)"> |
| <h3>groupAndSend</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">void</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-490">groupAndSend</a></span><wbr><span class="parameters">(<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/stream/Stream.html" title="class or interface in java.util.stream" class="external-link">Stream</a><<a href="Action.html" title="class in org.apache.hadoop.hbase.client">Action</a>> actions, |
| int tries)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="call()"> |
| <h3>call</h3> |
| <div class="member-signature"><span class="modifiers">public</span> <span class="return-type"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/concurrent/CompletableFuture.html" title="class or interface in java.util.concurrent" class="external-link">CompletableFuture</a><<a href="AsyncBatchRpcRetryingCaller.html" title="type parameter in AsyncBatchRpcRetryingCaller">T</a>>></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.html#line-529">call</a></span>()</div> |
| </section> |
| </li> |
| </ul> |
| </section> |
| </li> |
| </ul> |
| </section> |
| <!-- ========= END OF CLASS DATA ========= --> |
| </main> |
| <footer role="contentinfo"> |
| <hr> |
| <p class="legal-copy"><small>Copyright © 2007–2020 <a href="https://www.apache.org/">The Apache Software Foundation</a>. All rights reserved.</small></p> |
| </footer> |
| </div> |
| </div> |
| </body> |
| </html> |
