http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8847591c/devapidocs/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html b/devapidocs/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html index 7e97018..45e273d 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -50,7 +50,7 @@ var activeTableTab = "activeTableTab"; <div class="subNav"> <ul class="navList"> <li><a href="../../../../../org/apache/hadoop/hbase/ipc/FatalConnectionException.html" title="class in org.apache.hadoop.hbase.ipc"><span class="typeNameLink">Prev Class</span></a></li> -<li><a href="../../../../../org/apache/hadoop/hbase/ipc/HBaseRpcController.html" title="interface in org.apache.hadoop.hbase.ipc"><span class="typeNameLink">Next Class</span></a></li> +<li><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.FifoCallRunner.html" title="class in org.apache.hadoop.hbase.ipc"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> <li><a href="../../../../../index.html?org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html" target="_top">Frames</a></li> @@ -74,7 +74,7 @@ var activeTableTab = "activeTableTab"; <div> <ul class="subNavList"> <li>Summary: </li> -<li><a href="#nested.classes.inherited.from.class.org.apache.hadoop.hbase.ipc.RpcScheduler">Nested</a> | </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> @@ -114,7 +114,7 @@ var activeTableTab = "activeTableTab"; <li class="blockList"> <hr> <br> -<pre>public class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.36">FifoRpcScheduler</a> +<pre>public class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.38">FifoRpcScheduler</a> extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a></pre> <div class="block">A very simple RpcScheduler} that serves incoming requests in order. @@ -131,6 +131,17 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <!-- --> </a> <h3>Nested Class Summary</h3> +<table class="memberSummary" 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>private static class </code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.FifoCallRunner.html" title="class in org.apache.hadoop.hbase.ipc">FifoRpcScheduler.FifoCallRunner</a></span></code> </td> +</tr> +</table> <ul class="blockList"> <li class="blockList"><a name="nested.classes.inherited.from.class.org.apache.hadoop.hbase.ipc.RpcScheduler"> <!-- --> @@ -243,19 +254,25 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t </td> </tr> <tr id="i5" class="rowColor"> +<td class="colFirst"><code><a href="../../../../../org/apache/hadoop/hbase/ipc/CallQueueInfo.html" title="class in org.apache.hadoop.hbase.ipc">CallQueueInfo</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#getCallQueueInfo--">getCallQueueInfo</a></span>()</code> +<div class="block">Get call queue information</div> +</td> +</tr> +<tr id="i6" class="altColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#getGeneralQueueLength--">getGeneralQueueLength</a></span>()</code> <div class="block">Retrieves length of the general queue for metrics.</div> </td> </tr> -<tr id="i6" class="altColor"> +<tr id="i7" class="rowColor"> <td class="colFirst"><code>long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#getNumGeneralCallsDropped--">getNumGeneralCallsDropped</a></span>()</code> <div class="block">If CoDel-based RPC executors are used, retrieves the number of Calls that were dropped from general queue because RPC executor is under high load; returns 0 otherwise.</div> </td> </tr> -<tr id="i7" class="rowColor"> +<tr id="i8" class="altColor"> <td class="colFirst"><code>long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#getNumLifoModeSwitches--">getNumLifoModeSwitches</a></span>()</code> <div class="block">If CoDel-based RPC executors are used, retrieves the number of Calls that were @@ -263,49 +280,49 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t in the period of overloade we serve last requests first); returns 0 otherwise.</div> </td> </tr> -<tr id="i8" class="altColor"> +<tr id="i9" class="rowColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#getPriorityQueueLength--">getPriorityQueueLength</a></span>()</code> <div class="block">Retrieves length of the priority queue for metrics.</div> </td> </tr> -<tr id="i9" class="rowColor"> +<tr id="i10" class="altColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#getReadQueueLength--">getReadQueueLength</a></span>()</code> <div class="block">Retrieves length of the read queue for metrics when use RWQueueRpcExecutor.</div> </td> </tr> -<tr id="i10" class="altColor"> +<tr id="i11" class="rowColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#getReplicationQueueLength--">getReplicationQueueLength</a></span>()</code> <div class="block">Retrieves length of the replication queue for metrics.</div> </td> </tr> -<tr id="i11" class="rowColor"> +<tr id="i12" class="altColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#getScanQueueLength--">getScanQueueLength</a></span>()</code> <div class="block">Retrieves length of the scan queue for metrics when use RWQueueRpcExecutor.</div> </td> </tr> -<tr id="i12" class="altColor"> +<tr id="i13" class="rowColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#getWriteQueueLength--">getWriteQueueLength</a></span>()</code> <div class="block">Retrieves length of the write queue for metrics when use RWQueueRpcExecutor.</div> </td> </tr> -<tr id="i13" class="rowColor"> +<tr id="i14" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#init-org.apache.hadoop.hbase.ipc.RpcScheduler.Context-">init</a></span>(<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.Context.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler.Context</a> context)</code> <div class="block">Does some quick initialization.</div> </td> </tr> -<tr id="i14" class="altColor"> +<tr id="i15" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#start--">start</a></span>()</code> <div class="block">Prepares for request serving.</div> </td> </tr> -<tr id="i15" class="rowColor"> +<tr id="i16" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#stop--">stop</a></span>()</code> <div class="block">Stops serving new requests.</div> @@ -339,7 +356,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <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/ipc/FifoRpcScheduler.html#line.37">LOG</a></pre> +<pre>private static final org.apache.commons.logging.Log <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.39">LOG</a></pre> </li> </ul> <a name="handlerCount"> @@ -348,7 +365,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>handlerCount</h4> -<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.38">handlerCount</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.40">handlerCount</a></pre> </li> </ul> <a name="maxQueueLength"> @@ -357,7 +374,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>maxQueueLength</h4> -<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.39">maxQueueLength</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.41">maxQueueLength</a></pre> </li> </ul> <a name="queueSize"> @@ -366,7 +383,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>queueSize</h4> -<pre>private final <a href="http://docs.oracle.com/javase/8/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/ipc/FifoRpcScheduler.html#line.40">queueSize</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/8/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/ipc/FifoRpcScheduler.html#line.42">queueSize</a></pre> </li> </ul> <a name="executor"> @@ -375,7 +392,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockListLast"> <li class="blockList"> <h4>executor</h4> -<pre>private <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ThreadPoolExecutor.html?is-external=true"; title="class or interface in java.util.concurrent">ThreadPoolExecutor</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.41">executor</a></pre> +<pre>private <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ThreadPoolExecutor.html?is-external=true"; title="class or interface in java.util.concurrent">ThreadPoolExecutor</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.43">executor</a></pre> </li> </ul> </li> @@ -392,7 +409,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockListLast"> <li class="blockList"> <h4>FifoRpcScheduler</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.43">FifoRpcScheduler</a>(org.apache.hadoop.conf.Configuration conf, +<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.45">FifoRpcScheduler</a>(org.apache.hadoop.conf.Configuration conf, int handlerCount)</pre> </li> </ul> @@ -410,7 +427,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>init</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.52">init</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.Context.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler.Context</a> context)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.54">init</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.Context.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler.Context</a> context)</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#init-org.apache.hadoop.hbase.ipc.RpcScheduler.Context-">RpcScheduler</a></code></span></div> <div class="block">Does some quick initialization. Heavy tasks (e.g. starting threads) should be done in <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#start--"><code>RpcScheduler.start()</code></a>. This method is called before <code>start</code>.</div> @@ -428,7 +445,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>start</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.57">start</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.59">start</a>()</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#start--">RpcScheduler</a></code></span></div> <div class="block">Prepares for request serving. An implementation may start some handler threads here.</div> <dl> @@ -443,7 +460,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>stop</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.69">stop</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.71">stop</a>()</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#stop--">RpcScheduler</a></code></span></div> <div class="block">Stops serving new requests.</div> <dl> @@ -458,7 +475,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>dispatch</h4> -<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.74">dispatch</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/CallRunner.html" title="class in org.apache.hadoop.hbase.ipc">CallRunner</a> task) +<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.94">dispatch</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/CallRunner.html" title="class in org.apache.hadoop.hbase.ipc">CallRunner</a> task) throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> <div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#dispatch-org.apache.hadoop.hbase.ipc.CallRunner-">RpcScheduler</a></code></span></div> @@ -481,7 +498,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>getGeneralQueueLength</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.93">getGeneralQueueLength</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.115">getGeneralQueueLength</a>()</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#getGeneralQueueLength--">RpcScheduler</a></code></span></div> <div class="block">Retrieves length of the general queue for metrics.</div> <dl> @@ -496,7 +513,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>getPriorityQueueLength</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.98">getPriorityQueueLength</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.120">getPriorityQueueLength</a>()</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#getPriorityQueueLength--">RpcScheduler</a></code></span></div> <div class="block">Retrieves length of the priority queue for metrics.</div> <dl> @@ -511,7 +528,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>getReplicationQueueLength</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.103">getReplicationQueueLength</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.125">getReplicationQueueLength</a>()</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#getReplicationQueueLength--">RpcScheduler</a></code></span></div> <div class="block">Retrieves length of the replication queue for metrics.</div> <dl> @@ -526,7 +543,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>getActiveRpcHandlerCount</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.108">getActiveRpcHandlerCount</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.130">getActiveRpcHandlerCount</a>()</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#getActiveRpcHandlerCount--">RpcScheduler</a></code></span></div> <div class="block">Retrieves the number of active handler.</div> <dl> @@ -541,7 +558,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>getNumGeneralCallsDropped</h4> -<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.113">getNumGeneralCallsDropped</a>()</pre> +<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.135">getNumGeneralCallsDropped</a>()</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#getNumGeneralCallsDropped--">RpcScheduler</a></code></span></div> <div class="block">If CoDel-based RPC executors are used, retrieves the number of Calls that were dropped from general queue because RPC executor is under high load; returns 0 otherwise.</div> @@ -557,7 +574,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>getNumLifoModeSwitches</h4> -<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.118">getNumLifoModeSwitches</a>()</pre> +<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.140">getNumLifoModeSwitches</a>()</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#getNumLifoModeSwitches--">RpcScheduler</a></code></span></div> <div class="block">If CoDel-based RPC executors are used, retrieves the number of Calls that were picked from the tail of the queue (indicating adaptive LIFO mode, when @@ -574,7 +591,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>getWriteQueueLength</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.123">getWriteQueueLength</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.145">getWriteQueueLength</a>()</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#getWriteQueueLength--">RpcScheduler</a></code></span></div> <div class="block">Retrieves length of the write queue for metrics when use RWQueueRpcExecutor.</div> <dl> @@ -589,7 +606,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>getReadQueueLength</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.128">getReadQueueLength</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.150">getReadQueueLength</a>()</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#getReadQueueLength--">RpcScheduler</a></code></span></div> <div class="block">Retrieves length of the read queue for metrics when use RWQueueRpcExecutor.</div> <dl> @@ -604,7 +621,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>getScanQueueLength</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.133">getScanQueueLength</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.155">getScanQueueLength</a>()</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#getScanQueueLength--">RpcScheduler</a></code></span></div> <div class="block">Retrieves length of the scan queue for metrics when use RWQueueRpcExecutor.</div> <dl> @@ -619,7 +636,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>getActiveWriteRpcHandlerCount</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.138">getActiveWriteRpcHandlerCount</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.160">getActiveWriteRpcHandlerCount</a>()</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#getActiveWriteRpcHandlerCount--">RpcScheduler</a></code></span></div> <div class="block">Retrieves the number of active write rpc handler when use RWQueueRpcExecutor.</div> <dl> @@ -634,7 +651,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <ul class="blockList"> <li class="blockList"> <h4>getActiveReadRpcHandlerCount</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.143">getActiveReadRpcHandlerCount</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.165">getActiveReadRpcHandlerCount</a>()</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#getActiveReadRpcHandlerCount--">RpcScheduler</a></code></span></div> <div class="block">Retrieves the number of active write rpc handler when use RWQueueRpcExecutor.</div> <dl> @@ -646,10 +663,10 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <a name="getActiveScanRpcHandlerCount--"> <!-- --> </a> -<ul class="blockListLast"> +<ul class="blockList"> <li class="blockList"> <h4>getActiveScanRpcHandlerCount</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.148">getActiveScanRpcHandlerCount</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.170">getActiveScanRpcHandlerCount</a>()</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#getActiveScanRpcHandlerCount--">RpcScheduler</a></code></span></div> <div class="block">Retrieves the number of active write rpc handler when use RWQueueRpcExecutor.</div> <dl> @@ -658,6 +675,21 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t </dl> </li> </ul> +<a name="getCallQueueInfo--"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>getCallQueueInfo</h4> +<pre>public <a href="../../../../../org/apache/hadoop/hbase/ipc/CallQueueInfo.html" title="class in org.apache.hadoop.hbase.ipc">CallQueueInfo</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html#line.175">getCallQueueInfo</a>()</pre> +<div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#getCallQueueInfo--">RpcScheduler</a></code></span></div> +<div class="block">Get call queue information</div> +<dl> +<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> +<dd><code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#getCallQueueInfo--">getCallQueueInfo</a></code> in class <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a></code></dd> +</dl> +</li> +</ul> </li> </ul> </li> @@ -687,7 +719,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <div class="subNav"> <ul class="navList"> <li><a href="../../../../../org/apache/hadoop/hbase/ipc/FatalConnectionException.html" title="class in org.apache.hadoop.hbase.ipc"><span class="typeNameLink">Prev Class</span></a></li> -<li><a href="../../../../../org/apache/hadoop/hbase/ipc/HBaseRpcController.html" title="interface in org.apache.hadoop.hbase.ipc"><span class="typeNameLink">Next Class</span></a></li> +<li><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.FifoCallRunner.html" title="class in org.apache.hadoop.hbase.ipc"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> <li><a href="../../../../../index.html?org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html" target="_top">Frames</a></li> @@ -711,7 +743,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" t <div> <ul class="subNavList"> <li>Summary: </li> -<li><a href="#nested.classes.inherited.from.class.org.apache.hadoop.hbase.ipc.RpcScheduler">Nested</a> | </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>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8847591c/devapidocs/org/apache/hadoop/hbase/ipc/HBaseRpcController.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/HBaseRpcController.html b/devapidocs/org/apache/hadoop/hbase/ipc/HBaseRpcController.html index 46042dc..849cdaf 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/HBaseRpcController.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/HBaseRpcController.html @@ -49,7 +49,7 @@ var activeTableTab = "activeTableTab"; </div> <div class="subNav"> <ul class="navList"> -<li><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc"><span class="typeNameLink">Prev Class</span></a></li> +<li><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.FifoCallRunner.html" title="class in org.apache.hadoop.hbase.ipc"><span class="typeNameLink">Prev Class</span></a></li> <li><a href="../../../../../org/apache/hadoop/hbase/ipc/HBaseRpcController.CancellationCallback.html" title="interface in org.apache.hadoop.hbase.ipc"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> @@ -428,7 +428,7 @@ extends org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController, <a hre </div> <div class="subNav"> <ul class="navList"> -<li><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc"><span class="typeNameLink">Prev Class</span></a></li> +<li><a href="../../../../../org/apache/hadoop/hbase/ipc/FifoRpcScheduler.FifoCallRunner.html" title="class in org.apache.hadoop.hbase.ipc"><span class="typeNameLink">Prev Class</span></a></li> <li><a href="../../../../../org/apache/hadoop/hbase/ipc/HBaseRpcController.CancellationCallback.html" title="interface in org.apache.hadoop.hbase.ipc"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8847591c/devapidocs/org/apache/hadoop/hbase/ipc/RWQueueRpcExecutor.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RWQueueRpcExecutor.html b/devapidocs/org/apache/hadoop/hbase/ipc/RWQueueRpcExecutor.html index e87ade5..ff4bd71 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RWQueueRpcExecutor.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RWQueueRpcExecutor.html @@ -327,7 +327,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html" ti <!-- --> </a> <h3>Methods inherited from class org.apache.hadoop.hbase.ipc.<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html" title="class in org.apache.hadoop.hbase.ipc">RpcExecutor</a></h3> -<code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getBalancer-int-">getBalancer</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getHandler-java.lang.String-double-java.util.concurrent.BlockingQueue-java.util.concurrent.atomic.AtomicInteger-">getHandler</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getName--">getName</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getNumGeneralCallsDropped--">getNumGeneralCallsDropped</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getNumLifoModeSwitches--">getNumLifoModeSwitches</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getQueueLength--">getQueueLength</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getQueues--">getQueues</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#initializeQueues-int-">initializeQueues</a>, <a href="../../../../../o rg/apache/hadoop/hbase/ipc/RpcExecutor.html#isCodelQueueType-java.lang.String-">isCodelQueueType</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#isDeadlineQueueType-java.lang.String-">isDeadlineQueueType</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#isFifoQueueType-java.lang.String-">isFifoQueueType</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#onConfigurationChange-org.apache.hadoop.conf.Configuration-">onConfigurationChange</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#resizeQueues-org.apache.hadoop.conf.Configuration-">resizeQueues</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#start-int-">start</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#startHandlers-java.lang.String-int-java.util.List-int-int-int-java.util.concurrent.atomic.AtomicInteger-">startHandlers</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/Rpc Executor.html#stop--">stop</a></code></li> +<code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getBalancer-int-">getBalancer</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getCallQueueCountsSummary--">getCallQueueCountsSummary</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getCallQueueSizeSummary--">getCallQueueSizeSummary</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getHandler-java.lang.String-double-java.util.concurrent.BlockingQueue-java.util.concurrent.atomic.AtomicInteger-">getHandler</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getName--">getName</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getNumGeneralCallsDropped--">getNumGeneralCallsDropped</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getNumLifoModeSwitches--">getNumLifoModeSwitches</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getQueueLength--">ge tQueueLength</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getQueues--">getQueues</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#initializeQueues-int-">initializeQueues</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#isCodelQueueType-java.lang.String-">isCodelQueueType</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#isDeadlineQueueType-java.lang.String-">isDeadlineQueueType</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#isFifoQueueType-java.lang.String-">isFifoQueueType</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#onConfigurationChange-org.apache.hadoop.conf.Configuration-">onConfigurationChange</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#resizeQueues-org.apache.hadoop.conf.Configuration-">resizeQueues</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#start-int-">start< /a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#startHandlers-java.lang.String-int-java.util.List-int-int-int-java.util.concurrent.atomic.AtomicInteger-">startHandlers</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#stop--">stop</a></code></li> </ul> <ul class="blockList"> <li class="blockList"><a name="methods.inherited.from.class.java.lang.Object"> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8847591c/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html index 591bcb9..8001815 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html @@ -117,7 +117,7 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>private static class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.352">RpcExecutor.CallPriorityComparator</a> +<pre>private static class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.399">RpcExecutor.CallPriorityComparator</a> extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> implements <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Comparator.html?is-external=true"; title="class or interface in java.util">Comparator</a><<a href="../../../../../org/apache/hadoop/hbase/ipc/CallRunner.html" title="class in org.apache.hadoop.hbase.ipc">CallRunner</a>></pre> <div class="block">Comparator used by the "normal callQueue" if DEADLINE_CALL_QUEUE_CONF_KEY is set to true. It @@ -227,7 +227,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Comparato <ul class="blockList"> <li class="blockList"> <h4>DEFAULT_MAX_CALL_DELAY</h4> -<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html#line.353">DEFAULT_MAX_CALL_DELAY</a></pre> +<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html#line.400">DEFAULT_MAX_CALL_DELAY</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcExecutor.CallPriorityComparator.DEFAULT_MAX_CALL_DELAY">Constant Field Values</a></dd> @@ -240,7 +240,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Comparato <ul class="blockList"> <li class="blockList"> <h4>priority</h4> -<pre>private final <a href="../../../../../org/apache/hadoop/hbase/ipc/PriorityFunction.html" title="interface in org.apache.hadoop.hbase.ipc">PriorityFunction</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html#line.355">priority</a></pre> +<pre>private final <a href="../../../../../org/apache/hadoop/hbase/ipc/PriorityFunction.html" title="interface in org.apache.hadoop.hbase.ipc">PriorityFunction</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html#line.402">priority</a></pre> </li> </ul> <a name="maxDelay"> @@ -249,7 +249,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Comparato <ul class="blockListLast"> <li class="blockList"> <h4>maxDelay</h4> -<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html#line.356">maxDelay</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html#line.403">maxDelay</a></pre> </li> </ul> </li> @@ -266,7 +266,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Comparato <ul class="blockListLast"> <li class="blockList"> <h4>CallPriorityComparator</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html#line.358">CallPriorityComparator</a>(org.apache.hadoop.conf.Configuration conf, +<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html#line.405">CallPriorityComparator</a>(org.apache.hadoop.conf.Configuration conf, <a href="../../../../../org/apache/hadoop/hbase/ipc/PriorityFunction.html" title="interface in org.apache.hadoop.hbase.ipc">PriorityFunction</a> priority)</pre> </li> </ul> @@ -284,7 +284,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Comparato <ul class="blockListLast"> <li class="blockList"> <h4>compare</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html#line.364">compare</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/CallRunner.html" title="class in org.apache.hadoop.hbase.ipc">CallRunner</a> a, +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html#line.411">compare</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/CallRunner.html" title="class in org.apache.hadoop.hbase.ipc">CallRunner</a> a, <a href="../../../../../org/apache/hadoop/hbase/ipc/CallRunner.html" title="class in org.apache.hadoop.hbase.ipc">CallRunner</a> b)</pre> <dl> <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8847591c/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html index 4986e04..64f236b 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html @@ -126,7 +126,7 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>protected class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.224">RpcExecutor.Handler</a> +<pre>protected class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.271">RpcExecutor.Handler</a> extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true"; title="class or interface in java.lang">Thread</a></pre> <div class="block">Handler thread run the <a href="../../../../../org/apache/hadoop/hbase/ipc/CallRunner.html#run--"><code>CallRunner.run()</code></a> in.</div> </li> @@ -265,7 +265,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>q</h4> -<pre>final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/BlockingQueue.html?is-external=true"; title="class or interface in java.util.concurrent">BlockingQueue</a><<a href="../../../../../org/apache/hadoop/hbase/ipc/CallRunner.html" title="class in org.apache.hadoop.hbase.ipc">CallRunner</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html#line.228">q</a></pre> +<pre>final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/BlockingQueue.html?is-external=true"; title="class or interface in java.util.concurrent">BlockingQueue</a><<a href="../../../../../org/apache/hadoop/hbase/ipc/CallRunner.html" title="class in org.apache.hadoop.hbase.ipc">CallRunner</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html#line.275">q</a></pre> <div class="block">Q to find CallRunners to run in.</div> </li> </ul> @@ -275,7 +275,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>handlerFailureThreshhold</h4> -<pre>final double <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html#line.230">handlerFailureThreshhold</a></pre> +<pre>final double <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html#line.277">handlerFailureThreshhold</a></pre> </li> </ul> <a name="activeHandlerCount"> @@ -284,7 +284,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? <ul class="blockListLast"> <li class="blockList"> <h4>activeHandlerCount</h4> -<pre>final <a href="http://docs.oracle.com/javase/8/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/ipc/RpcExecutor.Handler.html#line.233">activeHandlerCount</a></pre> +<pre>final <a href="http://docs.oracle.com/javase/8/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/ipc/RpcExecutor.Handler.html#line.280">activeHandlerCount</a></pre> </li> </ul> </li> @@ -301,7 +301,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? <ul class="blockListLast"> <li class="blockList"> <h4>Handler</h4> -<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html#line.235">Handler</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> name, +<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html#line.282">Handler</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> name, double handlerFailureThreshhold, <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/BlockingQueue.html?is-external=true"; title="class or interface in java.util.concurrent">BlockingQueue</a><<a href="../../../../../org/apache/hadoop/hbase/ipc/CallRunner.html" title="class in org.apache.hadoop.hbase.ipc">CallRunner</a>> q, <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a> activeHandlerCount)</pre> @@ -321,7 +321,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>getCallRunner</h4> -<pre>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/CallRunner.html" title="class in org.apache.hadoop.hbase.ipc">CallRunner</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html#line.248">getCallRunner</a>() +<pre>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/CallRunner.html" title="class in org.apache.hadoop.hbase.ipc">CallRunner</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html#line.295">getCallRunner</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> <dl> <dt><span class="returnLabel">Returns:</span></dt> @@ -337,7 +337,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>run</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html#line.253">run</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html#line.300">run</a>()</pre> <dl> <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true#run--"; title="class or interface in java.lang">run</a></code> in interface <code><a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true"; title="class or interface in java.lang">Runnable</a></code></dd> @@ -352,7 +352,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? <ul class="blockListLast"> <li class="blockList"> <h4>run</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html#line.273">run</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/CallRunner.html" title="class in org.apache.hadoop.hbase.ipc">CallRunner</a> cr)</pre> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html#line.320">run</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/CallRunner.html" title="class in org.apache.hadoop.hbase.ipc">CallRunner</a> cr)</pre> </li> </ul> </li> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8847591c/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html index f15356f..a67c6e2 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html @@ -117,7 +117,7 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>public abstract static class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.305">RpcExecutor.QueueBalancer</a> +<pre>public abstract static class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.352">RpcExecutor.QueueBalancer</a> extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a></pre> </li> </ul> @@ -186,7 +186,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>QueueBalancer</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html#line.305">QueueBalancer</a>()</pre> +<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html#line.352">QueueBalancer</a>()</pre> </li> </ul> </li> @@ -203,7 +203,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>getNextQueue</h4> -<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html#line.309">getNextQueue</a>()</pre> +<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html#line.356">getNextQueue</a>()</pre> <dl> <dt><span class="returnLabel">Returns:</span></dt> <dd>the index of the next queue to which a request should be inserted</dd> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8847591c/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.RandomQueueBalancer.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.RandomQueueBalancer.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.RandomQueueBalancer.html index 4b288b6..5c09bf6 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.RandomQueueBalancer.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.RandomQueueBalancer.html @@ -118,7 +118,7 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>private static class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.334">RpcExecutor.RandomQueueBalancer</a> +<pre>private static class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.381">RpcExecutor.RandomQueueBalancer</a> extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html" title="class in org.apache.hadoop.hbase.ipc">RpcExecutor.QueueBalancer</a></pre> <div class="block">Queue balancer that just randomly selects a queue in the range [0, num queues).</div> </li> @@ -207,7 +207,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBal <ul class="blockListLast"> <li class="blockList"> <h4>queueSize</h4> -<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.RandomQueueBalancer.html#line.335">queueSize</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.RandomQueueBalancer.html#line.382">queueSize</a></pre> </li> </ul> </li> @@ -224,7 +224,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBal <ul class="blockListLast"> <li class="blockList"> <h4>RandomQueueBalancer</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.RandomQueueBalancer.html#line.337">RandomQueueBalancer</a>(int queueSize)</pre> +<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.RandomQueueBalancer.html#line.384">RandomQueueBalancer</a>(int queueSize)</pre> </li> </ul> </li> @@ -241,7 +241,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBal <ul class="blockListLast"> <li class="blockList"> <h4>getNextQueue</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.RandomQueueBalancer.html#line.341">getNextQueue</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.RandomQueueBalancer.html#line.388">getNextQueue</a>()</pre> <dl> <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> <dd><code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html#getNextQueue--">getNextQueue</a></code> in class <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html" title="class in org.apache.hadoop.hbase.ipc">RpcExecutor.QueueBalancer</a></code></dd>
