http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8847591c/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.html index e019ffa..f5a097d 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcExecutor.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":6,"i2":10,"i3":10,"i4":10,"i5":10,"i6":9,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":9,"i18":9,"i19":9,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10}; +var methods = {"i0":10,"i1":6,"i2":10,"i3":10,"i4":10,"i5":10,"i6":9,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":9,"i20":9,"i21":9,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10}; var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],4:["t3","Abstract Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -114,7 +114,7 @@ var activeTableTab = "activeTableTab"; <hr> <br> <pre>@InterfaceAudience.Private -public abstract class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.50">RpcExecutor</a> +public abstract class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.53">RpcExecutor</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> <div class="block">Runs the CallRunners passed here via <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#dispatch-org.apache.hadoop.hbase.ipc.CallRunner-"><code>dispatch(CallRunner)</code></a>. Subclass and add particular scheduling behavior.</div> @@ -385,6 +385,14 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getBalancer-int-">getBalancer</a></span>(int queueSize)</code> </td> </tr> <tr id="i7" class="rowColor"> +<td class="colFirst"><code><a href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</a>></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getCallQueueCountsSummary--">getCallQueueCountsSummary</a></span>()</code> </td> +</tr> +<tr id="i8" class="altColor"> +<td class="colFirst"><code><a href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</a>></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getCallQueueSizeSummary--">getCallQueueSizeSummary</a></span>()</code> </td> +</tr> +<tr id="i9" class="rowColor"> <td class="colFirst"><code>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html" title="class in org.apache.hadoop.hbase.ipc">RpcExecutor.Handler</a></code></td> <td class="colLast"><code><span class="memberNameLink"><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></span>(<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, @@ -393,77 +401,77 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <div class="block">Override if providing alternate Handler implementation.</div> </td> </tr> -<tr id="i8" class="altColor"> +<tr id="i10" class="altColor"> <td class="colFirst"><code><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></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getName--">getName</a></span>()</code> </td> </tr> -<tr id="i9" class="rowColor"> +<tr id="i11" class="rowColor"> <td class="colFirst"><code>long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getNumGeneralCallsDropped--">getNumGeneralCallsDropped</a></span>()</code> </td> </tr> -<tr id="i10" class="altColor"> +<tr id="i12" class="altColor"> <td class="colFirst"><code>long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getNumLifoModeSwitches--">getNumLifoModeSwitches</a></span>()</code> </td> </tr> -<tr id="i11" class="rowColor"> +<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/RpcExecutor.html#getQueueLength--">getQueueLength</a></span>()</code> <div class="block">Returns the length of the pending queue</div> </td> </tr> -<tr id="i12" class="altColor"> +<tr id="i14" class="altColor"> <td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/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>>></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getQueues--">getQueues</a></span>()</code> <div class="block">Returns the list of request queues</div> </td> </tr> -<tr id="i13" class="rowColor"> +<tr id="i15" class="rowColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getReadQueueLength--">getReadQueueLength</a></span>()</code> </td> </tr> -<tr id="i14" class="altColor"> +<tr id="i16" class="altColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getScanQueueLength--">getScanQueueLength</a></span>()</code> </td> </tr> -<tr id="i15" class="rowColor"> +<tr id="i17" class="rowColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#getWriteQueueLength--">getWriteQueueLength</a></span>()</code> </td> </tr> -<tr id="i16" class="altColor"> +<tr id="i18" class="altColor"> <td class="colFirst"><code>protected void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#initializeQueues-int-">initializeQueues</a></span>(int numQueues)</code> </td> </tr> -<tr id="i17" class="rowColor"> +<tr id="i19" class="rowColor"> <td class="colFirst"><code>static boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#isCodelQueueType-java.lang.String-">isCodelQueueType</a></span>(<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> callQueueType)</code> </td> </tr> -<tr id="i18" class="altColor"> +<tr id="i20" class="altColor"> <td class="colFirst"><code>static boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#isDeadlineQueueType-java.lang.String-">isDeadlineQueueType</a></span>(<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> callQueueType)</code> </td> </tr> -<tr id="i19" class="rowColor"> +<tr id="i21" class="rowColor"> <td class="colFirst"><code>static boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#isFifoQueueType-java.lang.String-">isFifoQueueType</a></span>(<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> callQueueType)</code> </td> </tr> -<tr id="i20" class="altColor"> +<tr id="i22" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#onConfigurationChange-org.apache.hadoop.conf.Configuration-">onConfigurationChange</a></span>(org.apache.hadoop.conf.Configuration conf)</code> </td> </tr> -<tr id="i21" class="rowColor"> +<tr id="i23" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#resizeQueues-org.apache.hadoop.conf.Configuration-">resizeQueues</a></span>(org.apache.hadoop.conf.Configuration conf)</code> <div class="block">Update current soft limit for executor's call queues</div> </td> </tr> -<tr id="i22" class="altColor"> +<tr id="i24" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#start-int-">start</a></span>(int port)</code> </td> </tr> -<tr id="i23" class="rowColor"> +<tr id="i25" class="rowColor"> <td class="colFirst"><code>protected void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#startHandlers-int-">startHandlers</a></span>(int port)</code> </td> </tr> -<tr id="i24" class="altColor"> +<tr id="i26" class="altColor"> <td class="colFirst"><code>protected void</code></td> <td class="colLast"><code><span class="memberNameLink"><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></span>(<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> nameSuffix, int numHandlers, @@ -475,7 +483,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <div class="block">Start up our handlers.</div> </td> </tr> -<tr id="i25" class="rowColor"> +<tr id="i27" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.html#stop--">stop</a></span>()</code> </td> </tr> @@ -507,7 +515,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>LOG</h4> -<pre>private static final org.apache.commons.logging.Log <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.51">LOG</a></pre> +<pre>private static final org.apache.commons.logging.Log <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.54">LOG</a></pre> </li> </ul> <a name="DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT"> @@ -516,7 +524,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT</h4> -<pre>protected static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.53">DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT</a></pre> +<pre>protected static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.56">DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcExecutor.DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT">Constant Field Values</a></dd> @@ -529,7 +537,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>CALL_QUEUE_HANDLER_FACTOR_CONF_KEY</h4> -<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.54">CALL_QUEUE_HANDLER_FACTOR_CONF_KEY</a></pre> +<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.57">CALL_QUEUE_HANDLER_FACTOR_CONF_KEY</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcExecutor.CALL_QUEUE_HANDLER_FACTOR_CONF_KEY">Constant Field Values</a></dd> @@ -542,7 +550,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>QUEUE_MAX_CALL_DELAY_CONF_KEY</h4> -<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.57">QUEUE_MAX_CALL_DELAY_CONF_KEY</a></pre> +<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.60">QUEUE_MAX_CALL_DELAY_CONF_KEY</a></pre> <div class="block">max delay in msec used to bound the deprioritized requests</div> <dl> <dt><span class="seeLabel">See Also:</span></dt> @@ -556,7 +564,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>CALL_QUEUE_TYPE_CODEL_CONF_VALUE</h4> -<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.64">CALL_QUEUE_TYPE_CODEL_CONF_VALUE</a></pre> +<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.67">CALL_QUEUE_TYPE_CODEL_CONF_VALUE</a></pre> <div class="block">The default, 'fifo', has the least friction but is dumb. If set to 'deadline', uses a priority queue and deprioritizes long-running scans. Sorting by priority comes at a cost, reduced throughput.</div> @@ -572,7 +580,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>CALL_QUEUE_TYPE_DEADLINE_CONF_VALUE</h4> -<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.65">CALL_QUEUE_TYPE_DEADLINE_CONF_VALUE</a></pre> +<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.68">CALL_QUEUE_TYPE_DEADLINE_CONF_VALUE</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcExecutor.CALL_QUEUE_TYPE_DEADLINE_CONF_VALUE">Constant Field Values</a></dd> @@ -585,7 +593,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>CALL_QUEUE_TYPE_FIFO_CONF_VALUE</h4> -<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.66">CALL_QUEUE_TYPE_FIFO_CONF_VALUE</a></pre> +<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.69">CALL_QUEUE_TYPE_FIFO_CONF_VALUE</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcExecutor.CALL_QUEUE_TYPE_FIFO_CONF_VALUE">Constant Field Values</a></dd> @@ -598,7 +606,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>CALL_QUEUE_TYPE_CONF_KEY</h4> -<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.67">CALL_QUEUE_TYPE_CONF_KEY</a></pre> +<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.70">CALL_QUEUE_TYPE_CONF_KEY</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcExecutor.CALL_QUEUE_TYPE_CONF_KEY">Constant Field Values</a></dd> @@ -611,7 +619,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>CALL_QUEUE_TYPE_CONF_DEFAULT</h4> -<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.68">CALL_QUEUE_TYPE_CONF_DEFAULT</a></pre> +<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.71">CALL_QUEUE_TYPE_CONF_DEFAULT</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcExecutor.CALL_QUEUE_TYPE_CONF_DEFAULT">Constant Field Values</a></dd> @@ -624,7 +632,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>CALL_QUEUE_CODEL_TARGET_DELAY</h4> -<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.71">CALL_QUEUE_CODEL_TARGET_DELAY</a></pre> +<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.74">CALL_QUEUE_CODEL_TARGET_DELAY</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcExecutor.CALL_QUEUE_CODEL_TARGET_DELAY">Constant Field Values</a></dd> @@ -637,7 +645,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>CALL_QUEUE_CODEL_INTERVAL</h4> -<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.72">CALL_QUEUE_CODEL_INTERVAL</a></pre> +<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.75">CALL_QUEUE_CODEL_INTERVAL</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcExecutor.CALL_QUEUE_CODEL_INTERVAL">Constant Field Values</a></dd> @@ -650,7 +658,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>CALL_QUEUE_CODEL_LIFO_THRESHOLD</h4> -<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.73">CALL_QUEUE_CODEL_LIFO_THRESHOLD</a></pre> +<pre>public static final <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.76">CALL_QUEUE_CODEL_LIFO_THRESHOLD</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcExecutor.CALL_QUEUE_CODEL_LIFO_THRESHOLD">Constant Field Values</a></dd> @@ -663,7 +671,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>CALL_QUEUE_CODEL_DEFAULT_TARGET_DELAY</h4> -<pre>public static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.75">CALL_QUEUE_CODEL_DEFAULT_TARGET_DELAY</a></pre> +<pre>public static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.78">CALL_QUEUE_CODEL_DEFAULT_TARGET_DELAY</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcExecutor.CALL_QUEUE_CODEL_DEFAULT_TARGET_DELAY">Constant Field Values</a></dd> @@ -676,7 +684,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>CALL_QUEUE_CODEL_DEFAULT_INTERVAL</h4> -<pre>public static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.76">CALL_QUEUE_CODEL_DEFAULT_INTERVAL</a></pre> +<pre>public static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.79">CALL_QUEUE_CODEL_DEFAULT_INTERVAL</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcExecutor.CALL_QUEUE_CODEL_DEFAULT_INTERVAL">Constant Field Values</a></dd> @@ -689,7 +697,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>CALL_QUEUE_CODEL_DEFAULT_LIFO_THRESHOLD</h4> -<pre>public static final double <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.77">CALL_QUEUE_CODEL_DEFAULT_LIFO_THRESHOLD</a></pre> +<pre>public static final double <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.80">CALL_QUEUE_CODEL_DEFAULT_LIFO_THRESHOLD</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcExecutor.CALL_QUEUE_CODEL_DEFAULT_LIFO_THRESHOLD">Constant Field Values</a></dd> @@ -702,7 +710,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>numGeneralCallsDropped</h4> -<pre>private <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/LongAdder.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">LongAdder</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.79">numGeneralCallsDropped</a></pre> +<pre>private <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/LongAdder.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">LongAdder</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.82">numGeneralCallsDropped</a></pre> </li> </ul> <a name="numLifoModeSwitches"> @@ -711,7 +719,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>numLifoModeSwitches</h4> -<pre>private <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/LongAdder.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">LongAdder</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.80">numLifoModeSwitches</a></pre> +<pre>private <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/LongAdder.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">LongAdder</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.83">numLifoModeSwitches</a></pre> </li> </ul> <a name="numCallQueues"> @@ -720,7 +728,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>numCallQueues</h4> -<pre>protected final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.82">numCallQueues</a></pre> +<pre>protected final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.85">numCallQueues</a></pre> </li> </ul> <a name="queues"> @@ -729,7 +737,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>queues</h4> -<pre>protected final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/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.html#line.83">queues</a></pre> +<pre>protected final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/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.html#line.86">queues</a></pre> </li> </ul> <a name="queueClass"> @@ -738,7 +746,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>queueClass</h4> -<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true"; title="class or interface in java.lang">Class</a><? extends <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="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.84">queueClass</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true"; title="class or interface in java.lang">Class</a><? extends <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="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.87">queueClass</a></pre> </li> </ul> <a name="queueInitArgs"> @@ -747,7 +755,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>queueInitArgs</h4> -<pre>private final <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>[] <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.85">queueInitArgs</a></pre> +<pre>private final <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>[] <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.88">queueInitArgs</a></pre> </li> </ul> <a name="priority"> @@ -756,7 +764,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <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.html#line.87">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.html#line.90">priority</a></pre> </li> </ul> <a name="currentQueueLimit"> @@ -765,7 +773,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>currentQueueLimit</h4> -<pre>protected volatile int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.89">currentQueueLimit</a></pre> +<pre>protected volatile int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.92">currentQueueLimit</a></pre> </li> </ul> <a name="activeHandlerCount"> @@ -774,7 +782,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>activeHandlerCount</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/RpcExecutor.html#line.91">activeHandlerCount</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/RpcExecutor.html#line.94">activeHandlerCount</a></pre> </li> </ul> <a name="handlers"> @@ -783,7 +791,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>handlers</h4> -<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html" title="class in org.apache.hadoop.hbase.ipc">RpcExecutor.Handler</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.92">handlers</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html" title="class in org.apache.hadoop.hbase.ipc">RpcExecutor.Handler</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.95">handlers</a></pre> </li> </ul> <a name="handlerCount"> @@ -792,7 +800,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>handlerCount</h4> -<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.93">handlerCount</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.96">handlerCount</a></pre> </li> </ul> <a name="failedHandlerCount"> @@ -801,7 +809,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>failedHandlerCount</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/RpcExecutor.html#line.94">failedHandlerCount</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/RpcExecutor.html#line.97">failedHandlerCount</a></pre> </li> </ul> <a name="name"> @@ -810,7 +818,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>name</h4> -<pre>private <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.96">name</a></pre> +<pre>private <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.99">name</a></pre> </li> </ul> <a name="running"> @@ -819,7 +827,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>running</h4> -<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.97">running</a></pre> +<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.100">running</a></pre> </li> </ul> <a name="conf"> @@ -828,7 +836,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>conf</h4> -<pre>private org.apache.hadoop.conf.Configuration <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.99">conf</a></pre> +<pre>private org.apache.hadoop.conf.Configuration <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.102">conf</a></pre> </li> </ul> <a name="abortable"> @@ -837,7 +845,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>abortable</h4> -<pre>private <a href="../../../../../org/apache/hadoop/hbase/Abortable.html" title="interface in org.apache.hadoop.hbase">Abortable</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.100">abortable</a></pre> +<pre>private <a href="../../../../../org/apache/hadoop/hbase/Abortable.html" title="interface in org.apache.hadoop.hbase">Abortable</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.103">abortable</a></pre> </li> </ul> <a name="ONE_QUEUE"> @@ -846,7 +854,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>ONE_QUEUE</h4> -<pre>private static <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html" title="class in org.apache.hadoop.hbase.ipc">RpcExecutor.QueueBalancer</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.324">ONE_QUEUE</a></pre> +<pre>private static <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html" title="class in org.apache.hadoop.hbase.ipc">RpcExecutor.QueueBalancer</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.371">ONE_QUEUE</a></pre> <div class="block">All requests go to the first queue, at index 0</div> </li> </ul> @@ -864,7 +872,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>RpcExecutor</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.102">RpcExecutor</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>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.105">RpcExecutor</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, int handlerCount, int maxQueueLength, <a href="../../../../../org/apache/hadoop/hbase/ipc/PriorityFunction.html" title="interface in org.apache.hadoop.hbase.ipc">PriorityFunction</a> priority, @@ -878,7 +886,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>RpcExecutor</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.108">RpcExecutor</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>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.111">RpcExecutor</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, int handlerCount, <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> callQueueType, int maxQueueLength, @@ -901,17 +909,35 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>computeNumCallQueues</h4> -<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.150">computeNumCallQueues</a>(int handlerCount, +<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.153">computeNumCallQueues</a>(int handlerCount, float callQueuesHandlersFactor)</pre> </li> </ul> +<a name="getCallQueueCountsSummary--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getCallQueueCountsSummary</h4> +<pre>public <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.157">getCallQueueCountsSummary</a>()</pre> +</li> +</ul> +<a name="getCallQueueSizeSummary--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getCallQueueSizeSummary</h4> +<pre>public <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.178">getCallQueueSizeSummary</a>()</pre> +</li> +</ul> <a name="initializeQueues-int-"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>initializeQueues</h4> -<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.154">initializeQueues</a>(int numQueues)</pre> +<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.201">initializeQueues</a>(int numQueues)</pre> </li> </ul> <a name="start-int-"> @@ -920,7 +946,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>start</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.165">start</a>(int port)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.212">start</a>(int port)</pre> </li> </ul> <a name="stop--"> @@ -929,7 +955,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>stop</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.170">stop</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.217">stop</a>()</pre> </li> </ul> <a name="dispatch-org.apache.hadoop.hbase.ipc.CallRunner-"> @@ -938,7 +964,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>dispatch</h4> -<pre>public abstract boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.178">dispatch</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/CallRunner.html" title="class in org.apache.hadoop.hbase.ipc">CallRunner</a> callTask) +<pre>public abstract boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.225">dispatch</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/CallRunner.html" title="class in org.apache.hadoop.hbase.ipc">CallRunner</a> callTask) 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> <div class="block">Add the request to the executor queue</div> <dl> @@ -953,7 +979,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getQueues</h4> -<pre>protected <a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/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.html#line.181">getQueues</a>()</pre> +<pre>protected <a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/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.html#line.228">getQueues</a>()</pre> <div class="block">Returns the list of request queues</div> </li> </ul> @@ -963,7 +989,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>startHandlers</h4> -<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.185">startHandlers</a>(int port)</pre> +<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.232">startHandlers</a>(int port)</pre> </li> </ul> <a name="getHandler-java.lang.String-double-java.util.concurrent.BlockingQueue-java.util.concurrent.atomic.AtomicInteger-"> @@ -972,7 +998,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getHandler</h4> -<pre>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html" title="class in org.apache.hadoop.hbase.ipc">RpcExecutor.Handler</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.193">getHandler</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>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html" title="class in org.apache.hadoop.hbase.ipc">RpcExecutor.Handler</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.240">getHandler</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> @@ -985,7 +1011,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>startHandlers</h4> -<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.201">startHandlers</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> nameSuffix, +<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.248">startHandlers</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> nameSuffix, int numHandlers, <a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/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>>> callQueues, int qindex, @@ -1001,7 +1027,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getBalancer</h4> -<pre>public static <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html" title="class in org.apache.hadoop.hbase.ipc">RpcExecutor.QueueBalancer</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.312">getBalancer</a>(int queueSize)</pre> +<pre>public static <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html" title="class in org.apache.hadoop.hbase.ipc">RpcExecutor.QueueBalancer</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.359">getBalancer</a>(int queueSize)</pre> </li> </ul> <a name="isDeadlineQueueType-java.lang.String-"> @@ -1010,7 +1036,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>isDeadlineQueueType</h4> -<pre>public static boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.375">isDeadlineQueueType</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> callQueueType)</pre> +<pre>public static boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.422">isDeadlineQueueType</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> callQueueType)</pre> </li> </ul> <a name="isCodelQueueType-java.lang.String-"> @@ -1019,7 +1045,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>isCodelQueueType</h4> -<pre>public static boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.379">isCodelQueueType</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> callQueueType)</pre> +<pre>public static boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.426">isCodelQueueType</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> callQueueType)</pre> </li> </ul> <a name="isFifoQueueType-java.lang.String-"> @@ -1028,7 +1054,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>isFifoQueueType</h4> -<pre>public static boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.383">isFifoQueueType</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> callQueueType)</pre> +<pre>public static boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.430">isFifoQueueType</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> callQueueType)</pre> </li> </ul> <a name="getNumGeneralCallsDropped--"> @@ -1037,7 +1063,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getNumGeneralCallsDropped</h4> -<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.387">getNumGeneralCallsDropped</a>()</pre> +<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.434">getNumGeneralCallsDropped</a>()</pre> </li> </ul> <a name="getNumLifoModeSwitches--"> @@ -1046,7 +1072,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getNumLifoModeSwitches</h4> -<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.391">getNumLifoModeSwitches</a>()</pre> +<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.438">getNumLifoModeSwitches</a>()</pre> </li> </ul> <a name="getActiveHandlerCount--"> @@ -1055,7 +1081,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getActiveHandlerCount</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.395">getActiveHandlerCount</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.442">getActiveHandlerCount</a>()</pre> </li> </ul> <a name="getActiveWriteHandlerCount--"> @@ -1064,7 +1090,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getActiveWriteHandlerCount</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.399">getActiveWriteHandlerCount</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.446">getActiveWriteHandlerCount</a>()</pre> </li> </ul> <a name="getActiveReadHandlerCount--"> @@ -1073,7 +1099,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getActiveReadHandlerCount</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.403">getActiveReadHandlerCount</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.450">getActiveReadHandlerCount</a>()</pre> </li> </ul> <a name="getActiveScanHandlerCount--"> @@ -1082,7 +1108,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getActiveScanHandlerCount</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.407">getActiveScanHandlerCount</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.454">getActiveScanHandlerCount</a>()</pre> </li> </ul> <a name="getQueueLength--"> @@ -1091,7 +1117,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getQueueLength</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.412">getQueueLength</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.459">getQueueLength</a>()</pre> <div class="block">Returns the length of the pending queue</div> </li> </ul> @@ -1101,7 +1127,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getReadQueueLength</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.420">getReadQueueLength</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.467">getReadQueueLength</a>()</pre> </li> </ul> <a name="getScanQueueLength--"> @@ -1110,7 +1136,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getScanQueueLength</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.424">getScanQueueLength</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.471">getScanQueueLength</a>()</pre> </li> </ul> <a name="getWriteQueueLength--"> @@ -1119,7 +1145,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getWriteQueueLength</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.428">getWriteQueueLength</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.475">getWriteQueueLength</a>()</pre> </li> </ul> <a name="getName--"> @@ -1128,7 +1154,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getName</h4> -<pre>public <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.432">getName</a>()</pre> +<pre>public <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> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.479">getName</a>()</pre> </li> </ul> <a name="resizeQueues-org.apache.hadoop.conf.Configuration-"> @@ -1137,7 +1163,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>resizeQueues</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.440">resizeQueues</a>(org.apache.hadoop.conf.Configuration conf)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.487">resizeQueues</a>(org.apache.hadoop.conf.Configuration conf)</pre> <div class="block">Update current soft limit for executor's call queues</div> <dl> <dt><span class="paramLabel">Parameters:</span></dt> @@ -1151,7 +1177,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>onConfigurationChange</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.448">onConfigurationChange</a>(org.apache.hadoop.conf.Configuration conf)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html#line.495">onConfigurationChange</a>(org.apache.hadoop.conf.Configuration conf)</pre> </li> </ul> </li>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8847591c/devapidocs/org/apache/hadoop/hbase/ipc/RpcScheduler.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcScheduler.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcScheduler.html index b08893f..6b79dc0 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcScheduler.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcScheduler.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6,"i8":6,"i9":6,"i10":6,"i11":6,"i12":6,"i13":6,"i14":6,"i15":6}; +var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6,"i8":6,"i9":6,"i10":6,"i11":6,"i12":6,"i13":6,"i14":6,"i15":6,"i16":6}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],4:["t3","Abstract Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -228,19 +228,25 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? </td> </tr> <tr id="i5" class="rowColor"> +<td class="colFirst"><code>abstract <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/RpcScheduler.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>abstract int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.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>abstract long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.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>abstract long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#getNumLifoModeSwitches--">getNumLifoModeSwitches</a></span>()</code> <div class="block">If CoDel-based RPC executors are used, retrieves the number of Calls that were @@ -248,49 +254,49 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? 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>abstract int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.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>abstract int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.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>abstract int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.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>abstract int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.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>abstract int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.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>abstract void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.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>abstract void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.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>abstract void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html#stop--">stop</a></span>()</code> <div class="block">Stops serving new requests.</div> @@ -424,13 +430,23 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? </dl> </li> </ul> +<a name="getCallQueueInfo--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getCallQueueInfo</h4> +<pre>public abstract <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/RpcScheduler.html#line.69">getCallQueueInfo</a>()</pre> +<div class="block">Get call queue information</div> +</li> +</ul> <a name="getGeneralQueueLength--"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>getGeneralQueueLength</h4> -<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.69">getGeneralQueueLength</a>()</pre> +<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.72">getGeneralQueueLength</a>()</pre> <div class="block">Retrieves length of the general queue for metrics.</div> </li> </ul> @@ -440,7 +456,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getPriorityQueueLength</h4> -<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.72">getPriorityQueueLength</a>()</pre> +<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.75">getPriorityQueueLength</a>()</pre> <div class="block">Retrieves length of the priority queue for metrics.</div> </li> </ul> @@ -450,7 +466,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getReplicationQueueLength</h4> -<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.75">getReplicationQueueLength</a>()</pre> +<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.78">getReplicationQueueLength</a>()</pre> <div class="block">Retrieves length of the replication queue for metrics.</div> </li> </ul> @@ -460,7 +476,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getActiveRpcHandlerCount</h4> -<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.78">getActiveRpcHandlerCount</a>()</pre> +<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.81">getActiveRpcHandlerCount</a>()</pre> <div class="block">Retrieves the number of active handler.</div> </li> </ul> @@ -470,7 +486,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getNumGeneralCallsDropped</h4> -<pre>public abstract long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.84">getNumGeneralCallsDropped</a>()</pre> +<pre>public abstract long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.87">getNumGeneralCallsDropped</a>()</pre> <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> </li> @@ -481,7 +497,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getNumLifoModeSwitches</h4> -<pre>public abstract long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.91">getNumLifoModeSwitches</a>()</pre> +<pre>public abstract long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.94">getNumLifoModeSwitches</a>()</pre> <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 in the period of overloade we serve last requests first); returns 0 otherwise.</div> @@ -493,7 +509,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getWriteQueueLength</h4> -<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.94">getWriteQueueLength</a>()</pre> +<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.97">getWriteQueueLength</a>()</pre> <div class="block">Retrieves length of the write queue for metrics when use RWQueueRpcExecutor.</div> </li> </ul> @@ -503,7 +519,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getReadQueueLength</h4> -<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.97">getReadQueueLength</a>()</pre> +<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.100">getReadQueueLength</a>()</pre> <div class="block">Retrieves length of the read queue for metrics when use RWQueueRpcExecutor.</div> </li> </ul> @@ -513,7 +529,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getScanQueueLength</h4> -<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.100">getScanQueueLength</a>()</pre> +<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.103">getScanQueueLength</a>()</pre> <div class="block">Retrieves length of the scan queue for metrics when use RWQueueRpcExecutor.</div> </li> </ul> @@ -523,7 +539,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getActiveWriteRpcHandlerCount</h4> -<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.103">getActiveWriteRpcHandlerCount</a>()</pre> +<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.106">getActiveWriteRpcHandlerCount</a>()</pre> <div class="block">Retrieves the number of active write rpc handler when use RWQueueRpcExecutor.</div> </li> </ul> @@ -533,7 +549,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getActiveReadRpcHandlerCount</h4> -<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.106">getActiveReadRpcHandlerCount</a>()</pre> +<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.109">getActiveReadRpcHandlerCount</a>()</pre> <div class="block">Retrieves the number of active write rpc handler when use RWQueueRpcExecutor.</div> </li> </ul> @@ -543,7 +559,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>getActiveScanRpcHandlerCount</h4> -<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.109">getActiveScanRpcHandlerCount</a>()</pre> +<pre>public abstract int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcScheduler.html#line.112">getActiveScanRpcHandlerCount</a>()</pre> <div class="block">Retrieves the number of active write rpc handler when use RWQueueRpcExecutor.</div> </li> </ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8847591c/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.html b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.html index 46751a0..afcf02f 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.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,"i16":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,"i17":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -278,19 +278,25 @@ implements <a href="../../../../../org/apache/hadoop/hbase/conf/ConfigurationObs </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/SimpleRpcScheduler.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/SimpleRpcScheduler.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/SimpleRpcScheduler.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/SimpleRpcScheduler.html#getNumLifoModeSwitches--">getNumLifoModeSwitches</a></span>()</code> <div class="block">If CoDel-based RPC executors are used, retrieves the number of Calls that were @@ -298,55 +304,55 @@ implements <a href="../../../../../org/apache/hadoop/hbase/conf/ConfigurationObs 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/SimpleRpcScheduler.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/SimpleRpcScheduler.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/SimpleRpcScheduler.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/SimpleRpcScheduler.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/SimpleRpcScheduler.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/SimpleRpcScheduler.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/SimpleRpcScheduler.html#onConfigurationChange-org.apache.hadoop.conf.Configuration-">onConfigurationChange</a></span>(org.apache.hadoop.conf.Configuration conf)</code> <div class="block">Resize call queues;</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/SimpleRpcScheduler.html#start--">start</a></span>()</code> <div class="block">Prepares for request serving.</div> </td> </tr> -<tr id="i16" class="altColor"> +<tr id="i17" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.html#stop--">stop</a></span>()</code> <div class="block">Stops serving new requests.</div> @@ -748,7 +754,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/conf/ConfigurationObs <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/SimpleRpcScheduler.html#line.229">getActiveScanRpcHandlerCount</a>()</pre> @@ -760,6 +766,21 @@ implements <a href="../../../../../org/apache/hadoop/hbase/conf/ConfigurationObs </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/SimpleRpcScheduler.html#line.234">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>
