http://git-wip-us.apache.org/repos/asf/hbase-site/blob/84ec2568/devapidocs/org/apache/hadoop/hbase/io/hfile/class-use/LruCachedBlock.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/io/hfile/class-use/LruCachedBlock.html b/devapidocs/org/apache/hadoop/hbase/io/hfile/class-use/LruCachedBlock.html index 65ec455..3c39891 100644 --- a/devapidocs/org/apache/hadoop/hbase/io/hfile/class-use/LruCachedBlock.html +++ b/devapidocs/org/apache/hadoop/hbase/io/hfile/class-use/LruCachedBlock.html @@ -148,14 +148,14 @@ <tbody> <tr class="altColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><span class="strong">LruBlockCache.BlockBucket.</span><code><strong><a href="../../../../../../../org/apache/hadoop/hbase/io/hfile/LruBlockCache.BlockBucket.html#add(org.apache.hadoop.hbase.io.hfile.LruCachedBlock)">add</a></strong>(<a href="../../../../../../../org/apache/hadoop/hbase/io/hfile/LruCachedBlock.html" title="class in org.apache.hadoop.hbase.io.hfile">LruCachedBlock</a> block)</code> </td> -</tr> -<tr class="rowColor"> -<td class="colFirst"><code>void</code></td> <td class="colLast"><span class="strong">LruCachedBlockQueue.</span><code><strong><a href="../../../../../../../org/apache/hadoop/hbase/io/hfile/LruCachedBlockQueue.html#add(org.apache.hadoop.hbase.io.hfile.LruCachedBlock)">add</a></strong>(<a href="../../../../../../../org/apache/hadoop/hbase/io/hfile/LruCachedBlock.html" title="class in org.apache.hadoop.hbase.io.hfile">LruCachedBlock</a> cb)</code> <div class="block">Attempt to add the specified cached block to this queue.</div> </td> </tr> +<tr class="rowColor"> +<td class="colFirst"><code>void</code></td> +<td class="colLast"><span class="strong">LruBlockCache.BlockBucket.</span><code><strong><a href="../../../../../../../org/apache/hadoop/hbase/io/hfile/LruBlockCache.BlockBucket.html#add(org.apache.hadoop.hbase.io.hfile.LruCachedBlock)">add</a></strong>(<a href="../../../../../../../org/apache/hadoop/hbase/io/hfile/LruCachedBlock.html" title="class in org.apache.hadoop.hbase.io.hfile">LruCachedBlock</a> block)</code> </td> +</tr> <tr class="altColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><span class="strong">LruCachedBlock.</span><code><strong><a href="../../../../../../../org/apache/hadoop/hbase/io/hfile/LruCachedBlock.html#compareTo(org.apache.hadoop.hbase.io.hfile.LruCachedBlock)">compareTo</a></strong>(<a href="../../../../../../../org/apache/hadoop/hbase/io/hfile/LruCachedBlock.html" title="class in org.apache.hadoop.hbase.io.hfile">LruCachedBlock</a> that)</code> </td>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/84ec2568/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html b/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html index c425aa0..9c8e4c0 100644 --- a/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html @@ -249,12 +249,12 @@ <ul> <li type="circle">java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Enum.html?is-external=true"; title="class or interface in java.lang"><span class="strong">Enum</span></a><E> (implements java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Comparable.html?is-external=true"; title="class or interface in java.lang">Comparable</a><T>, java.io.<a href="http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html?is-external=true"; title="class or interface in java.io">Serializable</a>) <ul> -<li type="circle">org.apache.hadoop.hbase.io.hfile.<a href="../../../../../../org/apache/hadoop/hbase/io/hfile/CacheConfig.ExternalBlockCaches.html" title="enum in org.apache.hadoop.hbase.io.hfile"><span class="strong">CacheConfig.ExternalBlockCaches</span></a></li> -<li type="circle">org.apache.hadoop.hbase.io.hfile.<a href="../../../../../../org/apache/hadoop/hbase/io/hfile/BlockType.html" title="enum in org.apache.hadoop.hbase.io.hfile"><span class="strong">BlockType</span></a></li> -<li type="circle">org.apache.hadoop.hbase.io.hfile.<a href="../../../../../../org/apache/hadoop/hbase/io/hfile/HFileBlock.Writer.State.html" title="enum in org.apache.hadoop.hbase.io.hfile"><span class="strong">HFileBlock.Writer.State</span></a></li> <li type="circle">org.apache.hadoop.hbase.io.hfile.<a href="../../../../../../org/apache/hadoop/hbase/io/hfile/BlockPriority.html" title="enum in org.apache.hadoop.hbase.io.hfile"><span class="strong">BlockPriority</span></a></li> +<li type="circle">org.apache.hadoop.hbase.io.hfile.<a href="../../../../../../org/apache/hadoop/hbase/io/hfile/BlockType.html" title="enum in org.apache.hadoop.hbase.io.hfile"><span class="strong">BlockType</span></a></li> <li type="circle">org.apache.hadoop.hbase.io.hfile.<a href="../../../../../../org/apache/hadoop/hbase/io/hfile/Cacheable.MemoryType.html" title="enum in org.apache.hadoop.hbase.io.hfile"><span class="strong">Cacheable.MemoryType</span></a></li> +<li type="circle">org.apache.hadoop.hbase.io.hfile.<a href="../../../../../../org/apache/hadoop/hbase/io/hfile/CacheConfig.ExternalBlockCaches.html" title="enum in org.apache.hadoop.hbase.io.hfile"><span class="strong">CacheConfig.ExternalBlockCaches</span></a></li> <li type="circle">org.apache.hadoop.hbase.io.hfile.<a href="../../../../../../org/apache/hadoop/hbase/io/hfile/BlockType.BlockCategory.html" title="enum in org.apache.hadoop.hbase.io.hfile"><span class="strong">BlockType.BlockCategory</span></a></li> +<li type="circle">org.apache.hadoop.hbase.io.hfile.<a href="../../../../../../org/apache/hadoop/hbase/io/hfile/HFileBlock.Writer.State.html" title="enum in org.apache.hadoop.hbase.io.hfile"><span class="strong">HFileBlock.Writer.State</span></a></li> </ul> </li> </ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/84ec2568/devapidocs/org/apache/hadoop/hbase/ipc/AbstractRpcClient.BlockingRpcChannelImplementation.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/AbstractRpcClient.BlockingRpcChannelImplementation.html b/devapidocs/org/apache/hadoop/hbase/ipc/AbstractRpcClient.BlockingRpcChannelImplementation.html index ba8a961..3ccc0db 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/AbstractRpcClient.BlockingRpcChannelImplementation.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/AbstractRpcClient.BlockingRpcChannelImplementation.html @@ -103,7 +103,7 @@ </dl> <hr> <br> -<pre>public static class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AbstractRpcClient.html#line.304">AbstractRpcClient.BlockingRpcChannelImplementation</a> +<pre>public static class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AbstractRpcClient.html#line.325">AbstractRpcClient.BlockingRpcChannelImplementation</a> extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> implements com.google.protobuf.BlockingRpcChannel</pre> <div class="block">Blocking rpc channel that goes via hbase rpc.</div> @@ -213,7 +213,7 @@ implements com.google.protobuf.BlockingRpcChannel</pre> <ul class="blockList"> <li class="blockList"> <h4>isa</h4> -<pre>private final <a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AbstractRpcClient.BlockingRpcChannelImplementation.html#line.305">isa</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AbstractRpcClient.BlockingRpcChannelImplementation.html#line.326">isa</a></pre> </li> </ul> <a name="rpcClient"> @@ -222,7 +222,7 @@ implements com.google.protobuf.BlockingRpcChannel</pre> <ul class="blockList"> <li class="blockList"> <h4>rpcClient</h4> -<pre>private final <a href="../../../../../org/apache/hadoop/hbase/ipc/AbstractRpcClient.html" title="class in org.apache.hadoop.hbase.ipc">AbstractRpcClient</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AbstractRpcClient.BlockingRpcChannelImplementation.html#line.306">rpcClient</a></pre> +<pre>private final <a href="../../../../../org/apache/hadoop/hbase/ipc/AbstractRpcClient.html" title="class in org.apache.hadoop.hbase.ipc">AbstractRpcClient</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AbstractRpcClient.BlockingRpcChannelImplementation.html#line.327">rpcClient</a></pre> </li> </ul> <a name="ticket"> @@ -231,7 +231,7 @@ implements com.google.protobuf.BlockingRpcChannel</pre> <ul class="blockList"> <li class="blockList"> <h4>ticket</h4> -<pre>private final <a href="../../../../../org/apache/hadoop/hbase/security/User.html" title="class in org.apache.hadoop.hbase.security">User</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AbstractRpcClient.BlockingRpcChannelImplementation.html#line.307">ticket</a></pre> +<pre>private final <a href="../../../../../org/apache/hadoop/hbase/security/User.html" title="class in org.apache.hadoop.hbase.security">User</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AbstractRpcClient.BlockingRpcChannelImplementation.html#line.328">ticket</a></pre> </li> </ul> <a name="channelOperationTimeout"> @@ -240,7 +240,7 @@ implements com.google.protobuf.BlockingRpcChannel</pre> <ul class="blockListLast"> <li class="blockList"> <h4>channelOperationTimeout</h4> -<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AbstractRpcClient.BlockingRpcChannelImplementation.html#line.308">channelOperationTimeout</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AbstractRpcClient.BlockingRpcChannelImplementation.html#line.329">channelOperationTimeout</a></pre> </li> </ul> </li> @@ -257,7 +257,7 @@ implements com.google.protobuf.BlockingRpcChannel</pre> <ul class="blockListLast"> <li class="blockList"> <h4>AbstractRpcClient.BlockingRpcChannelImplementation</h4> -<pre>protected <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AbstractRpcClient.BlockingRpcChannelImplementation.html#line.313">AbstractRpcClient.BlockingRpcChannelImplementation</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/AbstractRpcClient.html" title="class in org.apache.hadoop.hbase.ipc">AbstractRpcClient</a> rpcClient, +<pre>protected <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AbstractRpcClient.BlockingRpcChannelImplementation.html#line.334">AbstractRpcClient.BlockingRpcChannelImplementation</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/AbstractRpcClient.html" title="class in org.apache.hadoop.hbase.ipc">AbstractRpcClient</a> rpcClient, <a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> sn, <a href="../../../../../org/apache/hadoop/hbase/security/User.html" title="class in org.apache.hadoop.hbase.security">User</a> ticket, int channelOperationTimeout)</pre> @@ -278,7 +278,7 @@ implements com.google.protobuf.BlockingRpcChannel</pre> <ul class="blockListLast"> <li class="blockList"> <h4>callBlockingMethod</h4> -<pre>public com.google.protobuf.Message <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AbstractRpcClient.BlockingRpcChannelImplementation.html#line.322">callBlockingMethod</a>(com.google.protobuf.Descriptors.MethodDescriptor md, +<pre>public com.google.protobuf.Message <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AbstractRpcClient.BlockingRpcChannelImplementation.html#line.343">callBlockingMethod</a>(com.google.protobuf.Descriptors.MethodDescriptor md, com.google.protobuf.RpcController controller, com.google.protobuf.Message param, com.google.protobuf.Message returnType) http://git-wip-us.apache.org/repos/asf/hbase-site/blob/84ec2568/devapidocs/org/apache/hadoop/hbase/ipc/AbstractRpcClient.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/AbstractRpcClient.html b/devapidocs/org/apache/hadoop/hbase/ipc/AbstractRpcClient.html index 8d511ad..7cdd0b9 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/AbstractRpcClient.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/AbstractRpcClient.html @@ -289,6 +289,13 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcClient.html" t </td> </tr> <tr class="altColor"> +<td class="colFirst"><code>(package private) static <a href="../../../../../org/apache/hadoop/hbase/ipc/PayloadCarryingRpcController.html" title="class in org.apache.hadoop.hbase.ipc">PayloadCarryingRpcController</a></code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AbstractRpcClient.html#configurePayloadCarryingRpcController(com.google.protobuf.RpcController,%20int)">configurePayloadCarryingRpcController</a></strong>(com.google.protobuf.RpcController controller, + int channelOperationTimeout)</code> +<div class="block">Configure a payload carrying controller</div> +</td> +</tr> +<tr class="rowColor"> <td class="colFirst"><code>com.google.protobuf.BlockingRpcChannel</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AbstractRpcClient.html#createBlockingRpcChannel(org.apache.hadoop.hbase.ServerName,%20org.apache.hadoop.hbase.security.User,%20int)">createBlockingRpcChannel</a></strong>(<a href="../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> sn, <a href="../../../../../org/apache/hadoop/hbase/security/User.html" title="class in org.apache.hadoop.hbase.security">User</a> ticket, @@ -296,30 +303,30 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcClient.html" t <div class="block">Creates a "channel" that can be used by a blocking protobuf service.</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>(package private) <a href="../../../../../org/apache/hadoop/hbase/codec/Codec.html" title="interface in org.apache.hadoop.hbase.codec">Codec</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AbstractRpcClient.html#getCodec()">getCodec</a></strong>()</code> <div class="block">Encapsulate the ugly casting and RuntimeException conversion in private method.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private static org.apache.hadoop.io.compress.CompressionCodec</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AbstractRpcClient.html#getCompressor(org.apache.hadoop.conf.Configuration)">getCompressor</a></strong>(org.apache.hadoop.conf.Configuration conf)</code> <div class="block">Encapsulate the ugly casting and RuntimeException conversion in private method.</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>static <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AbstractRpcClient.html#getDefaultCodec(org.apache.hadoop.conf.Configuration)">getDefaultCodec</a></strong>(org.apache.hadoop.conf.Configuration c)</code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected static int</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AbstractRpcClient.html#getPoolSize(org.apache.hadoop.conf.Configuration)">getPoolSize</a></strong>(org.apache.hadoop.conf.Configuration config)</code> <div class="block">Return the pool size specified in the configuration, which is applicable only if the pool type is <a href="../../../../../org/apache/hadoop/hbase/util/PoolMap.PoolType.html#RoundRobin"><code>PoolMap.PoolType.RoundRobin</code></a>.</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>protected static <a href="../../../../../org/apache/hadoop/hbase/util/PoolMap.PoolType.html" title="enum in org.apache.hadoop.hbase.util">PoolMap.PoolType</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AbstractRpcClient.html#getPoolType(org.apache.hadoop.conf.Configuration)">getPoolType</a></strong>(org.apache.hadoop.conf.Configuration config)</code> <div class="block">Return the pool type specified in the configuration, which must be set to @@ -328,11 +335,11 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcClient.html" t otherwise default to the former.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AbstractRpcClient.html#hasCellBlockSupport()">hasCellBlockSupport</a></strong>()</code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AbstractRpcClient.html#wrapException(java.net.InetSocketAddress,%20java.lang.Exception)">wrapException</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> addr, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a> exception)</code> @@ -353,7 +360,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcClient.html" t <!-- --> </a> <h3>Methods inherited from interface org.apache.hadoop.hbase.ipc.<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcClient.html" title="interface in org.apache.hadoop.hbase.ipc">RpcClient</a></h3> -<code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcClient.html#cancelConnections(org.apache.hadoop.hbase.ServerName)">cancelConnections</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcClient.html#close()">close</a></code></li> +<code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcClient.html#cancelConnections(org.apache.hadoop.hbase.ServerName)">cancelConnections</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcClient.html#close()">close</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcClient.html#createProtobufRpcChannel(org.apache.hadoop.hbase.ServerName,%20org.apache.hadoop.hbase.security.User,%20int)">createProtobufRpcChannel</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcClient.html#createRpcChannel(java.lang.String,%20org.apache.hadoop.hbase.ServerName,%20org.apache.hadoop.hbase.security.User)">createRpcChannel</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcClient.html#getEventExecutor()">getEventExecutor</a></code></li> </ul> </li> </ul> @@ -715,13 +722,26 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcClient.html" t <dt><span class="strong">Returns:</span></dt><dd>A blocking rpc channel that goes via this rpc client instance.</dd></dl> </li> </ul> +<a name="configurePayloadCarryingRpcController(com.google.protobuf.RpcController, int)"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>configurePayloadCarryingRpcController</h4> +<pre>static <a href="../../../../../org/apache/hadoop/hbase/ipc/PayloadCarryingRpcController.html" title="class in org.apache.hadoop.hbase.ipc">PayloadCarryingRpcController</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AbstractRpcClient.html#line.279">configurePayloadCarryingRpcController</a>(com.google.protobuf.RpcController controller, + int channelOperationTimeout)</pre> +<div class="block">Configure a payload carrying controller</div> +<dl><dt><span class="strong">Parameters:</span></dt><dd><code>controller</code> - to configure</dd><dd><code>channelOperationTimeout</code> - timeout for operation</dd> +<dt><span class="strong">Returns:</span></dt><dd>configured payload controller</dd></dl> +</li> +</ul> <a name="wrapException(java.net.InetSocketAddress, java.lang.Exception)"> <!-- --> </a> <ul class="blockListLast"> <li class="blockList"> <h4>wrapException</h4> -<pre>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AbstractRpcClient.html#line.283">wrapException</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> addr, +<pre>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AbstractRpcClient.html#line.304">wrapException</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> addr, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a> exception)</pre> <div class="block">Takes an Exception and the address we were trying to connect to and return an IOException with the input exception as the cause. The new exception provides the stack trace of the place where http://git-wip-us.apache.org/repos/asf/hbase-site/blob/84ec2568/devapidocs/org/apache/hadoop/hbase/ipc/AsyncCall.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/AsyncCall.html b/devapidocs/org/apache/hadoop/hbase/ipc/AsyncCall.html index 986d7a3..27d90ff 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/AsyncCall.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/AsyncCall.html @@ -152,44 +152,44 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/Promise.html" title= <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html#channel">channel</a></strong></code> </td> </tr> <tr class="rowColor"> +<td class="colFirst"><code>(package private) <a href="../../../../../org/apache/hadoop/hbase/client/MetricsConnection.html" title="class in org.apache.hadoop.hbase.client">MetricsConnection</a></code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html#clientMetrics">clientMetrics</a></strong></code> </td> +</tr> +<tr class="altColor"> <td class="colFirst"><code>private <a href="../../../../../org/apache/hadoop/hbase/ipc/IOExceptionConverter.html" title="interface in org.apache.hadoop.hbase.ipc">IOExceptionConverter</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html#exceptionConverter">exceptionConverter</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>(package private) int</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html#id">id</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private static org.apache.commons.logging.Log</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html#LOG">LOG</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private <a href="../../../../../org/apache/hadoop/hbase/ipc/MessageConverter.html" title="interface in org.apache.hadoop.hbase.ipc">MessageConverter</a><<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html" title="type parameter in AsyncCall">M</a>,<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html" title="type parameter in AsyncCall">T</a>></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html#messageConverter">messageConverter</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>(package private) com.google.protobuf.Descriptors.MethodDescriptor</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html#method">method</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>(package private) com.google.protobuf.Message</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html#param">param</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private int</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html#priority">priority</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>(package private) com.google.protobuf.Message</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html#responseDefaultType">responseDefaultType</a></strong></code> </td> </tr> -<tr class="rowColor"> -<td class="colFirst"><code>(package private) long</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html#rpcTimeout">rpcTimeout</a></strong></code> </td> -</tr> <tr class="altColor"> <td class="colFirst"><code>(package private) long</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html#startTime">startTime</a></strong></code> </td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html#rpcTimeout">rpcTimeout</a></strong></code> </td> </tr> </table> </li> @@ -206,7 +206,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/Promise.html" title= <th class="colOne" scope="col">Constructor and Description</th> </tr> <tr class="altColor"> -<td class="colOne"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html#AsyncCall(org.apache.hadoop.hbase.ipc.AsyncRpcChannelImpl,%20int,%20com.google.protobuf.Descriptors.MethodDescriptor,%20com.google.protobuf.Message,%20org.apache.hadoop.hbase.CellScanner,%20M,%20org.apache.hadoop.hbase.ipc.MessageConverter,%20org.apache.hadoop.hbase.ipc.IOExceptionConverter,%20long,%20int,%20org.apache.hadoop.hbase.client.MetricsConnection.CallStats)">AsyncCall</a></strong>(<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html" title="class in org.apache.hadoop.hbase.ipc">AsyncRpcChannelImpl</a> channel, +<td class="colOne"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html#AsyncCall(org.apache.hadoop.hbase.ipc.AsyncRpcChannelImpl,%20int,%20com.google.protobuf.Descriptors.MethodDescriptor,%20com.google.protobuf.Message,%20org.apache.hadoop.hbase.CellScanner,%20M,%20org.apache.hadoop.hbase.ipc.MessageConverter,%20org.apache.hadoop.hbase.ipc.IOExceptionConverter,%20long,%20int,%20org.apache.hadoop.hbase.client.MetricsConnection)">AsyncCall</a></strong>(<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html" title="class in org.apache.hadoop.hbase.ipc">AsyncRpcChannelImpl</a> channel, int connectId, com.google.protobuf.Descriptors.MethodDescriptor md, com.google.protobuf.Message param, @@ -216,7 +216,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/Promise.html" title= <a href="../../../../../org/apache/hadoop/hbase/ipc/IOExceptionConverter.html" title="interface in org.apache.hadoop.hbase.ipc">IOExceptionConverter</a> exceptionConverter, long rpcTimeout, int priority, - <a href="../../../../../org/apache/hadoop/hbase/client/MetricsConnection.CallStats.html" title="class in org.apache.hadoop.hbase.client">MetricsConnection.CallStats</a> callStats)</code> + <a href="../../../../../org/apache/hadoop/hbase/client/MetricsConnection.html" title="class in org.apache.hadoop.hbase.client">MetricsConnection</a> metrics)</code> <div class="block">Constructor</div> </td> </tr> @@ -391,13 +391,13 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/Promise.html" title= <pre>private final <a href="../../../../../org/apache/hadoop/hbase/ipc/MessageConverter.html" title="interface in org.apache.hadoop.hbase.ipc">MessageConverter</a><<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html" title="type parameter in AsyncCall">M</a> extends com.google.protobuf.Message,<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html" title="type parameter in AsyncCall">T</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.53">messageConverter</a></pre> </li> </ul> -<a name="startTime"> +<a name="exceptionConverter"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> -<h4>startTime</h4> -<pre>final long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.54">startTime</a></pre> +<h4>exceptionConverter</h4> +<pre>private final <a href="../../../../../org/apache/hadoop/hbase/ipc/IOExceptionConverter.html" title="interface in org.apache.hadoop.hbase.ipc">IOExceptionConverter</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.54">exceptionConverter</a></pre> </li> </ul> <a name="rpcTimeout"> @@ -406,16 +406,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/Promise.html" title= <ul class="blockList"> <li class="blockList"> <h4>rpcTimeout</h4> -<pre>final long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.55">rpcTimeout</a></pre> -</li> -</ul> -<a name="exceptionConverter"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>exceptionConverter</h4> -<pre>private final <a href="../../../../../org/apache/hadoop/hbase/ipc/IOExceptionConverter.html" title="interface in org.apache.hadoop.hbase.ipc">IOExceptionConverter</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.56">exceptionConverter</a></pre> +<pre>final long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.56">rpcTimeout</a></pre> </li> </ul> <a name="cellScanner"> @@ -436,13 +427,22 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/Promise.html" title= <pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.60">priority</a></pre> </li> </ul> +<a name="clientMetrics"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>clientMetrics</h4> +<pre>final <a href="../../../../../org/apache/hadoop/hbase/client/MetricsConnection.html" title="class in org.apache.hadoop.hbase.client">MetricsConnection</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.62">clientMetrics</a></pre> +</li> +</ul> <a name="callStats"> <!-- --> </a> <ul class="blockListLast"> <li class="blockList"> <h4>callStats</h4> -<pre>final <a href="../../../../../org/apache/hadoop/hbase/client/MetricsConnection.CallStats.html" title="class in org.apache.hadoop.hbase.client">MetricsConnection.CallStats</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.62">callStats</a></pre> +<pre>final <a href="../../../../../org/apache/hadoop/hbase/client/MetricsConnection.CallStats.html" title="class in org.apache.hadoop.hbase.client">MetricsConnection.CallStats</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.63">callStats</a></pre> </li> </ul> </li> @@ -453,15 +453,15 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/Promise.html" title= <!-- --> </a> <h3>Constructor Detail</h3> -<a name="AsyncCall(org.apache.hadoop.hbase.ipc.AsyncRpcChannelImpl,int,com.google.protobuf.Descriptors.MethodDescriptor,com.google.protobuf.Message,org.apache.hadoop.hbase.CellScanner,com.google.protobuf.Message,org.apache.hadoop.hbase.ipc.MessageConverter,org.apache.hadoop.hbase.ipc.IOExceptionConverter,long,int,org.apache.hadoop.hbase.client.MetricsConnection.CallStats)"> +<a name="AsyncCall(org.apache.hadoop.hbase.ipc.AsyncRpcChannelImpl,int,com.google.protobuf.Descriptors.MethodDescriptor,com.google.protobuf.Message,org.apache.hadoop.hbase.CellScanner,com.google.protobuf.Message,org.apache.hadoop.hbase.ipc.MessageConverter,org.apache.hadoop.hbase.ipc.IOExceptionConverter,long,int,org.apache.hadoop.hbase.client.MetricsConnection)"> <!-- --> -</a><a name="AsyncCall(org.apache.hadoop.hbase.ipc.AsyncRpcChannelImpl, int, com.google.protobuf.Descriptors.MethodDescriptor, com.google.protobuf.Message, org.apache.hadoop.hbase.CellScanner, M, org.apache.hadoop.hbase.ipc.MessageConverter, org.apache.hadoop.hbase.ipc.IOExceptionConverter, long, int, org.apache.hadoop.hbase.client.MetricsConnection.CallStats)"> +</a><a name="AsyncCall(org.apache.hadoop.hbase.ipc.AsyncRpcChannelImpl, int, com.google.protobuf.Descriptors.MethodDescriptor, com.google.protobuf.Message, org.apache.hadoop.hbase.CellScanner, M, org.apache.hadoop.hbase.ipc.MessageConverter, org.apache.hadoop.hbase.ipc.IOExceptionConverter, long, int, org.apache.hadoop.hbase.client.MetricsConnection)"> <!-- --> </a> <ul class="blockListLast"> <li class="blockList"> <h4>AsyncCall</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.77">AsyncCall</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html" title="class in org.apache.hadoop.hbase.ipc">AsyncRpcChannelImpl</a> channel, +<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.80">AsyncCall</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html" title="class in org.apache.hadoop.hbase.ipc">AsyncRpcChannelImpl</a> channel, int connectId, com.google.protobuf.Descriptors.MethodDescriptor md, com.google.protobuf.Message param, @@ -471,9 +471,9 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/Promise.html" title= <a href="../../../../../org/apache/hadoop/hbase/ipc/IOExceptionConverter.html" title="interface in org.apache.hadoop.hbase.ipc">IOExceptionConverter</a> exceptionConverter, long rpcTimeout, int priority, - <a href="../../../../../org/apache/hadoop/hbase/client/MetricsConnection.CallStats.html" title="class in org.apache.hadoop.hbase.client">MetricsConnection.CallStats</a> callStats)</pre> + <a href="../../../../../org/apache/hadoop/hbase/client/MetricsConnection.html" title="class in org.apache.hadoop.hbase.client">MetricsConnection</a> metrics)</pre> <div class="block">Constructor</div> -<dl><dt><span class="strong">Parameters:</span></dt><dd><code>channel</code> - which initiated call</dd><dd><code>connectId</code> - connection id</dd><dd><code>md</code> - the method descriptor</dd><dd><code>param</code> - parameters to send to Server</dd><dd><code>cellScanner</code> - cellScanner containing cells to send as request</dd><dd><code>responseDefaultType</code> - the default response type</dd><dd><code>messageConverter</code> - converts the messages to what is the expected output</dd><dd><code>rpcTimeout</code> - timeout for this call in ms</dd><dd><code>priority</code> - for this request</dd></dl> +<dl><dt><span class="strong">Parameters:</span></dt><dd><code>channel</code> - which initiated call</dd><dd><code>connectId</code> - connection id</dd><dd><code>md</code> - the method descriptor</dd><dd><code>param</code> - parameters to send to Server</dd><dd><code>cellScanner</code> - cellScanner containing cells to send as request</dd><dd><code>responseDefaultType</code> - the default response type</dd><dd><code>messageConverter</code> - converts the messages to what is the expected output</dd><dd><code>exceptionConverter</code> - converts exceptions to expected format. Can be null</dd><dd><code>rpcTimeout</code> - timeout for this call in ms</dd><dd><code>priority</code> - for this request</dd><dd><code>metrics</code> - MetricsConnection to which the metrics are stored for this request</dd></dl> </li> </ul> </li> @@ -490,7 +490,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/Promise.html" title= <ul class="blockList"> <li class="blockList"> <h4>getStartTime</h4> -<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.107">getStartTime</a>()</pre> +<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.112">getStartTime</a>()</pre> <div class="block">Get the start time</div> <dl><dt><span class="strong">Returns:</span></dt><dd>start time for the call</dd></dl> </li> @@ -501,7 +501,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/Promise.html" title= <ul class="blockList"> <li class="blockList"> <h4>toString</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.112">toString</a>()</pre> +<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.117">toString</a>()</pre> <dl> <dt><strong>Overrides:</strong></dt> <dd><code>toString</code> in class <code>io.netty.util.concurrent.DefaultPromise<<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html" title="type parameter in AsyncCall">T</a>></code></dd> @@ -516,7 +516,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/Promise.html" title= <ul class="blockList"> <li class="blockList"> <h4>setSuccess</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.124">setSuccess</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html" title="type parameter in AsyncCall">M</a> value, +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.129">setSuccess</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html" title="type parameter in AsyncCall">M</a> value, <a href="../../../../../org/apache/hadoop/hbase/CellScanner.html" title="interface in org.apache.hadoop.hbase">CellScanner</a> cellBlockScanner)</pre> <div class="block">Set success with a cellBlockScanner</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>value</code> - to set</dd><dd><code>cellBlockScanner</code> - to set</dd></dl> @@ -528,7 +528,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/Promise.html" title= <ul class="blockList"> <li class="blockList"> <h4>setFailed</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.144">setFailed</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a> exception)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.154">setFailed</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a> exception)</pre> <div class="block">Set failed</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>exception</code> - to set</dd></dl> </li> @@ -539,7 +539,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/Promise.html" title= <ul class="blockList"> <li class="blockList"> <h4>getRpcTimeout</h4> -<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.164">getRpcTimeout</a>()</pre> +<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.174">getRpcTimeout</a>()</pre> <div class="block">Get the rpc timeout</div> <dl><dt><span class="strong">Returns:</span></dt><dd>current timeout for this call</dd></dl> </li> @@ -550,7 +550,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/Promise.html" title= <ul class="blockList"> <li class="blockList"> <h4>getPriority</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.172">getPriority</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.182">getPriority</a>()</pre> <dl><dt><span class="strong">Returns:</span></dt><dd>Priority for this call</dd></dl> </li> </ul> @@ -560,7 +560,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/Promise.html" title= <ul class="blockList"> <li class="blockList"> <h4>cellScanner</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/CellScanner.html" title="interface in org.apache.hadoop.hbase">CellScanner</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.180">cellScanner</a>()</pre> +<pre>public <a href="../../../../../org/apache/hadoop/hbase/CellScanner.html" title="interface in org.apache.hadoop.hbase">CellScanner</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.190">cellScanner</a>()</pre> <div class="block">Get the cellScanner for this request.</div> <dl><dt><span class="strong">Returns:</span></dt><dd>CellScanner</dd></dl> </li> @@ -571,7 +571,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/Promise.html" title= <ul class="blockListLast"> <li class="blockList"> <h4>cancel</h4> -<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.185">cancel</a>(boolean mayInterupt)</pre> +<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncCall.html#line.195">cancel</a>(boolean mayInterupt)</pre> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Future.html?is-external=true#cancel(boolean)" title="class or interface in java.util.concurrent">cancel</a></code> in interface <code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Future.html?is-external=true"; title="class or interface in java.util.concurrent">Future</a><<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html" title="type parameter in AsyncCall">T</a>></code></dd> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/84ec2568/devapidocs/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html b/devapidocs/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html index 34394b2..e721068 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html @@ -87,12 +87,12 @@ <li class="blockList"> <dl> <dt>All Known Implementing Classes:</dt> -<dd><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html" title="class in org.apache.hadoop.hbase.ipc">AsyncRpcChannelImpl</a></dd> +<dd><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html" title="class in org.apache.hadoop.hbase.ipc">AsyncRpcChannelImpl</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcClientImpl.AsyncRpcChannel.html" title="class in org.apache.hadoop.hbase.ipc">RpcClientImpl.AsyncRpcChannel</a></dd> </dl> <hr> <br> <pre><a href="../../../../../org/apache/hadoop/hbase/classification/InterfaceAudience.Private.html" title="annotation in org.apache.hadoop.hbase.classification">@InterfaceAudience.Private</a> -public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.36">AsyncRpcChannel</a></pre> +public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.35">AsyncRpcChannel</a></pre> <div class="block">Interface for Async Rpc Channels</div> </li> </ul> @@ -114,15 +114,14 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/As </tr> <tr class="altColor"> <td class="colFirst"><code><R extends com.google.protobuf.Message,O> <br><a href="../../../../../org/apache/hadoop/hbase/client/Future.html" title="interface in org.apache.hadoop.hbase.client">Future</a><O></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#callMethod(com.google.protobuf.Descriptors.MethodDescriptor,%20com.google.protobuf.Message,%20org.apache.hadoop.hbase.CellScanner,%20R,%20org.apache.hadoop.hbase.ipc.MessageConverter,%20org.apache.hadoop.hbase.ipc.IOExceptionConverter,%20long,%20int,%20org.apache.hadoop.hbase.client.MetricsConnection.CallStats)">callMethod</a></strong>(com.google.protobuf.Descriptors.MethodDescriptor method, +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#callMethod(com.google.protobuf.Descriptors.MethodDescriptor,%20com.google.protobuf.Message,%20org.apache.hadoop.hbase.CellScanner,%20R,%20org.apache.hadoop.hbase.ipc.MessageConverter,%20org.apache.hadoop.hbase.ipc.IOExceptionConverter,%20long,%20int)">callMethod</a></strong>(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.Message request, <a href="../../../../../org/apache/hadoop/hbase/CellScanner.html" title="interface in org.apache.hadoop.hbase">CellScanner</a> cellScanner, R responsePrototype, <a href="../../../../../org/apache/hadoop/hbase/ipc/MessageConverter.html" title="interface in org.apache.hadoop.hbase.ipc">MessageConverter</a><R,O> messageConverter, <a href="../../../../../org/apache/hadoop/hbase/ipc/IOExceptionConverter.html" title="interface in org.apache.hadoop.hbase.ipc">IOExceptionConverter</a> exceptionConverter, long rpcTimeout, - int priority, - <a href="../../../../../org/apache/hadoop/hbase/client/MetricsConnection.CallStats.html" title="class in org.apache.hadoop.hbase.client">MetricsConnection.CallStats</a> callStats)</code> + int priority)</code> <div class="block">Calls method on channel</div> </td> </tr> @@ -165,25 +164,24 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/As <!-- --> </a> <h3>Method Detail</h3> -<a name="callMethod(com.google.protobuf.Descriptors.MethodDescriptor,com.google.protobuf.Message,org.apache.hadoop.hbase.CellScanner,com.google.protobuf.Message,org.apache.hadoop.hbase.ipc.MessageConverter,org.apache.hadoop.hbase.ipc.IOExceptionConverter,long,int,org.apache.hadoop.hbase.client.MetricsConnection.CallStats)"> +<a name="callMethod(com.google.protobuf.Descriptors.MethodDescriptor,com.google.protobuf.Message,org.apache.hadoop.hbase.CellScanner,com.google.protobuf.Message,org.apache.hadoop.hbase.ipc.MessageConverter,org.apache.hadoop.hbase.ipc.IOExceptionConverter,long,int)"> <!-- --> -</a><a name="callMethod(com.google.protobuf.Descriptors.MethodDescriptor, com.google.protobuf.Message, org.apache.hadoop.hbase.CellScanner, R, org.apache.hadoop.hbase.ipc.MessageConverter, org.apache.hadoop.hbase.ipc.IOExceptionConverter, long, int, org.apache.hadoop.hbase.client.MetricsConnection.CallStats)"> +</a><a name="callMethod(com.google.protobuf.Descriptors.MethodDescriptor, com.google.protobuf.Message, org.apache.hadoop.hbase.CellScanner, R, org.apache.hadoop.hbase.ipc.MessageConverter, org.apache.hadoop.hbase.ipc.IOExceptionConverter, long, int)"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>callMethod</h4> -<pre><R extends com.google.protobuf.Message,O> <a href="../../../../../org/apache/hadoop/hbase/client/Future.html" title="interface in org.apache.hadoop.hbase.client">Future</a><O> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.52">callMethod</a>(com.google.protobuf.Descriptors.MethodDescriptor method, +<pre><R extends com.google.protobuf.Message,O> <a href="../../../../../org/apache/hadoop/hbase/client/Future.html" title="interface in org.apache.hadoop.hbase.client">Future</a><O> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.49">callMethod</a>(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.Message request, <a href="../../../../../org/apache/hadoop/hbase/CellScanner.html" title="interface in org.apache.hadoop.hbase">CellScanner</a> cellScanner, R responsePrototype, <a href="../../../../../org/apache/hadoop/hbase/ipc/MessageConverter.html" title="interface in org.apache.hadoop.hbase.ipc">MessageConverter</a><R,O> messageConverter, <a href="../../../../../org/apache/hadoop/hbase/ipc/IOExceptionConverter.html" title="interface in org.apache.hadoop.hbase.ipc">IOExceptionConverter</a> exceptionConverter, long rpcTimeout, - int priority, - <a href="../../../../../org/apache/hadoop/hbase/client/MetricsConnection.CallStats.html" title="class in org.apache.hadoop.hbase.client">MetricsConnection.CallStats</a> callStats)</pre> + int priority)</pre> <div class="block">Calls method on channel</div> -<dl><dt><span class="strong">Parameters:</span></dt><dd><code>method</code> - to call</dd><dd><code>request</code> - to send</dd><dd><code>cellScanner</code> - with cells to send</dd><dd><code>responsePrototype</code> - to construct response with</dd><dd><code>messageConverter</code> - for the messages to expected result</dd><dd><code>exceptionConverter</code> - for converting exceptions</dd><dd><code>rpcTimeout</code> - timeout for request</dd><dd><code>priority</code> - for request</dd><dd><code>callStats</code> - collects stats of the call</dd> +<dl><dt><span class="strong">Parameters:</span></dt><dd><code>method</code> - to call</dd><dd><code>request</code> - to send</dd><dd><code>cellScanner</code> - with cells to send</dd><dd><code>responsePrototype</code> - to construct response with</dd><dd><code>messageConverter</code> - for the messages to expected result</dd><dd><code>exceptionConverter</code> - for converting exceptions</dd><dd><code>rpcTimeout</code> - timeout for request</dd><dd><code>priority</code> - for request</dd> <dt><span class="strong">Returns:</span></dt><dd>Promise for the response Message</dd></dl> </li> </ul> @@ -193,7 +191,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/As <ul class="blockList"> <li class="blockList"> <h4>getEventExecutor</h4> -<pre>io.netty.util.concurrent.EventExecutor <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.63">getEventExecutor</a>()</pre> +<pre>io.netty.util.concurrent.EventExecutor <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.60">getEventExecutor</a>()</pre> <div class="block">Get the EventLoop on which this channel operated</div> <dl><dt><span class="strong">Returns:</span></dt><dd>EventLoop</dd></dl> </li> @@ -204,7 +202,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/As <ul class="blockList"> <li class="blockList"> <h4>close</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.69">close</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true"; title="class or interface in java.lang">Throwable</a> cause)</pre> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.66">close</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true"; title="class or interface in java.lang">Throwable</a> cause)</pre> <div class="block">Close connection</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>cause</code> - of closure.</dd></dl> </li> @@ -215,7 +213,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/As <ul class="blockList"> <li class="blockList"> <h4>isAlive</h4> -<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.76">isAlive</a>()</pre> +<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.73">isAlive</a>()</pre> <div class="block">Check if the connection is alive</div> <dl><dt><span class="strong">Returns:</span></dt><dd>true if alive</dd></dl> </li> @@ -226,7 +224,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/As <ul class="blockListLast"> <li class="blockList"> <h4>getAddress</h4> -<pre><a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.82">getAddress</a>()</pre> +<pre><a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.79">getAddress</a>()</pre> <div class="block">Get the address on which this channel operates</div> <dl><dt><span class="strong">Returns:</span></dt><dd>InetSocketAddress</dd></dl> </li> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/84ec2568/devapidocs/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html b/devapidocs/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html index ebf2136..60d31d3 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html @@ -100,7 +100,7 @@ <hr> <br> <pre><a href="../../../../../org/apache/hadoop/hbase/classification/InterfaceAudience.Private.html" title="annotation in org.apache.hadoop.hbase.classification">@InterfaceAudience.Private</a> -public class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.83">AsyncRpcChannelImpl</a> +public class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.81">AsyncRpcChannelImpl</a> extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html" title="interface in org.apache.hadoop.hbase.ipc">AsyncRpcChannel</a></pre> <div class="block">Netty RPC channel</div> @@ -270,15 +270,14 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h </tr> <tr class="rowColor"> <td class="colFirst"><code><R extends com.google.protobuf.Message,O> <br><a href="../../../../../org/apache/hadoop/hbase/client/Future.html" title="interface in org.apache.hadoop.hbase.client">Future</a><O></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#callMethod(com.google.protobuf.Descriptors.MethodDescriptor,%20com.google.protobuf.Message,%20org.apache.hadoop.hbase.CellScanner,%20R,%20org.apache.hadoop.hbase.ipc.MessageConverter,%20org.apache.hadoop.hbase.ipc.IOExceptionConverter,%20long,%20int,%20org.apache.hadoop.hbase.client.MetricsConnection.CallStats)">callMethod</a></strong>(com.google.protobuf.Descriptors.MethodDescriptor method, +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#callMethod(com.google.protobuf.Descriptors.MethodDescriptor,%20com.google.protobuf.Message,%20org.apache.hadoop.hbase.CellScanner,%20R,%20org.apache.hadoop.hbase.ipc.MessageConverter,%20org.apache.hadoop.hbase.ipc.IOExceptionConverter,%20long,%20int)">callMethod</a></strong>(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.Message request, <a href="../../../../../org/apache/hadoop/hbase/CellScanner.html" title="interface in org.apache.hadoop.hbase">CellScanner</a> cellScanner, R responsePrototype, <a href="../../../../../org/apache/hadoop/hbase/ipc/MessageConverter.html" title="interface in org.apache.hadoop.hbase.ipc">MessageConverter</a><R,O> messageConverter, <a href="../../../../../org/apache/hadoop/hbase/ipc/IOExceptionConverter.html" title="interface in org.apache.hadoop.hbase.ipc">IOExceptionConverter</a> exceptionConverter, long rpcTimeout, - int priority, - <a href="../../../../../org/apache/hadoop/hbase/client/MetricsConnection.CallStats.html" title="class in org.apache.hadoop.hbase.client">MetricsConnection.CallStats</a> callStats)</code> + int priority)</code> <div class="block">Calls method on channel</div> </td> </tr> @@ -432,7 +431,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <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/AsyncRpcChannelImpl.html#line.84">LOG</a></pre> +<pre>private static final org.apache.commons.logging.Log <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.82">LOG</a></pre> </li> </ul> <a name="MAX_SASL_RETRIES"> @@ -441,7 +440,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>MAX_SASL_RETRIES</h4> -<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.86">MAX_SASL_RETRIES</a></pre> +<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.84">MAX_SASL_RETRIES</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.AsyncRpcChannelImpl.MAX_SASL_RETRIES">Constant Field Values</a></dd></dl> </li> </ul> @@ -451,7 +450,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>TOKEN_HANDDLERS</h4> -<pre>protected static final <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.TokenIdentifier.Kind,org.apache.hadoop.security.token.TokenSelector<? extends org.apache.hadoop.security.token.TokenIdentifier>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.88">TOKEN_HANDDLERS</a></pre> +<pre>protected static final <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.TokenIdentifier.Kind,org.apache.hadoop.security.token.TokenSelector<? extends org.apache.hadoop.security.token.TokenIdentifier>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.86">TOKEN_HANDDLERS</a></pre> </li> </ul> <a name="client"> @@ -460,7 +459,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>client</h4> -<pre>final <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcClient.html" title="class in org.apache.hadoop.hbase.ipc">AsyncRpcClient</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.96">client</a></pre> +<pre>final <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcClient.html" title="class in org.apache.hadoop.hbase.ipc">AsyncRpcClient</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.94">client</a></pre> </li> </ul> <a name="channel"> @@ -469,7 +468,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>channel</h4> -<pre>private io.netty.channel.Channel <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.100">channel</a></pre> +<pre>private io.netty.channel.Channel <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.98">channel</a></pre> </li> </ul> <a name="name"> @@ -478,7 +477,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>name</h4> -<pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.102">name</a></pre> +<pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.100">name</a></pre> </li> </ul> <a name="ticket"> @@ -487,7 +486,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>ticket</h4> -<pre>final <a href="../../../../../org/apache/hadoop/hbase/security/User.html" title="class in org.apache.hadoop.hbase.security">User</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.103">ticket</a></pre> +<pre>final <a href="../../../../../org/apache/hadoop/hbase/security/User.html" title="class in org.apache.hadoop.hbase.security">User</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.101">ticket</a></pre> </li> </ul> <a name="serviceName"> @@ -496,7 +495,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>serviceName</h4> -<pre>final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.104">serviceName</a></pre> +<pre>final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.102">serviceName</a></pre> </li> </ul> <a name="address"> @@ -505,7 +504,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>address</h4> -<pre>final <a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.105">address</a></pre> +<pre>final <a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.103">address</a></pre> </li> </ul> <a name="failureCounter"> @@ -514,7 +513,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>failureCounter</h4> -<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.107">failureCounter</a></pre> +<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.105">failureCounter</a></pre> </li> </ul> <a name="useSasl"> @@ -523,7 +522,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>useSasl</h4> -<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.109">useSasl</a></pre> +<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.107">useSasl</a></pre> </li> </ul> <a name="authMethod"> @@ -532,7 +531,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>authMethod</h4> -<pre><a href="../../../../../org/apache/hadoop/hbase/security/AuthMethod.html" title="enum in org.apache.hadoop.hbase.security">AuthMethod</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.110">authMethod</a></pre> +<pre><a href="../../../../../org/apache/hadoop/hbase/security/AuthMethod.html" title="enum in org.apache.hadoop.hbase.security">AuthMethod</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.108">authMethod</a></pre> </li> </ul> <a name="reloginMaxBackoff"> @@ -541,7 +540,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>reloginMaxBackoff</h4> -<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.111">reloginMaxBackoff</a></pre> +<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.109">reloginMaxBackoff</a></pre> </li> </ul> <a name="token"> @@ -550,7 +549,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>token</h4> -<pre>private org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.112">token</a></pre> +<pre>private org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.110">token</a></pre> </li> </ul> <a name="serverPrincipal"> @@ -559,7 +558,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>serverPrincipal</h4> -<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.113">serverPrincipal</a></pre> +<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.111">serverPrincipal</a></pre> </li> </ul> <a name="pendingCalls"> @@ -568,7 +567,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>pendingCalls</h4> -<pre>private final <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>,<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html" title="class in org.apache.hadoop.hbase.ipc">AsyncCall</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.116">pendingCalls</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>,<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html" title="class in org.apache.hadoop.hbase.ipc">AsyncCall</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.114">pendingCalls</a></pre> </li> </ul> <a name="connected"> @@ -577,7 +576,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>connected</h4> -<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.117">connected</a></pre> +<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.115">connected</a></pre> </li> </ul> <a name="closed"> @@ -586,7 +585,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>closed</h4> -<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.118">closed</a></pre> +<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.116">closed</a></pre> </li> </ul> <a name="cleanupTimer"> @@ -595,7 +594,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>cleanupTimer</h4> -<pre>private io.netty.util.Timeout <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.120">cleanupTimer</a></pre> +<pre>private io.netty.util.Timeout <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.118">cleanupTimer</a></pre> </li> </ul> <a name="timeoutTask"> @@ -604,7 +603,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockListLast"> <li class="blockList"> <h4>timeoutTask</h4> -<pre>private final io.netty.util.TimerTask <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.122">timeoutTask</a></pre> +<pre>private final io.netty.util.TimerTask <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.120">timeoutTask</a></pre> </li> </ul> </li> @@ -621,7 +620,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockListLast"> <li class="blockList"> <h4>AsyncRpcChannelImpl</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.137">AsyncRpcChannelImpl</a>(io.netty.bootstrap.Bootstrap bootstrap, +<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.135">AsyncRpcChannelImpl</a>(io.netty.bootstrap.Bootstrap bootstrap, <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcClient.html" title="class in org.apache.hadoop.hbase.ipc">AsyncRpcClient</a> client, <a href="../../../../../org/apache/hadoop/hbase/security/User.html" title="class in org.apache.hadoop.hbase.security">User</a> ticket, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> serviceName, @@ -644,7 +643,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>connect</h4> -<pre>private io.netty.channel.ChannelFuture <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.156">connect</a>(io.netty.bootstrap.Bootstrap bootstrap)</pre> +<pre>private io.netty.channel.ChannelFuture <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.154">connect</a>(io.netty.bootstrap.Bootstrap bootstrap)</pre> <div class="block">Connect to channel</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>bootstrap</code> - to connect to</dd> <dt><span class="strong">Returns:</span></dt><dd>future of connection</dd></dl> @@ -656,7 +655,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>startHBaseConnection</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.209">startHBaseConnection</a>(io.netty.channel.Channel ch)</pre> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.207">startHBaseConnection</a>(io.netty.channel.Channel ch)</pre> <div class="block">Start HBase connection</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>ch</code> - channel to start connection on</dd></dl> </li> @@ -667,7 +666,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>getSaslHandler</h4> -<pre>private <a href="../../../../../org/apache/hadoop/hbase/security/SaslClientHandler.html" title="class in org.apache.hadoop.hbase.security">SaslClientHandler</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.242">getSaslHandler</a>(org.apache.hadoop.security.UserGroupInformation realTicket, +<pre>private <a href="../../../../../org/apache/hadoop/hbase/security/SaslClientHandler.html" title="class in org.apache.hadoop.hbase.security">SaslClientHandler</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.240">getSaslHandler</a>(org.apache.hadoop.security.UserGroupInformation realTicket, io.netty.bootstrap.Bootstrap bootstrap) throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <div class="block">Get SASL handler</div> @@ -683,7 +682,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <ul class="blockList"> <li class="blockList"> <h4>retryOrClose</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.275">retryOrClose</a>(io.netty.bootstrap.Bootstrap bootstrap, +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.273">retryOrClose</a>(io.netty.bootstrap.Bootstrap bootstrap, int failureCount, long timeout, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true"; title="class or interface in java.lang">Throwable</a> e)</pre> @@ -691,28 +690,27 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.h <dl><dt><span class="strong">Parameters:</span></dt><dd><code>bootstrap</code> - to connect with</dd><dd><code>failureCount</code> - failure count</dd><dd><code>e</code> - exception of fail</dd></dl> </li> </ul> -<a name="callMethod(com.google.protobuf.Descriptors.MethodDescriptor,com.google.protobuf.Message,org.apache.hadoop.hbase.CellScanner,com.google.protobuf.Message,org.apache.hadoop.hbase.ipc.MessageConverter,org.apache.hadoop.hbase.ipc.IOExceptionConverter,long,int,org.apache.hadoop.hbase.client.MetricsConnection.CallStats)"> +<a name="callMethod(com.google.protobuf.Descriptors.MethodDescriptor,com.google.protobuf.Message,org.apache.hadoop.hbase.CellScanner,com.google.protobuf.Message,org.apache.hadoop.hbase.ipc.MessageConverter,org.apache.hadoop.hbase.ipc.IOExceptionConverter,long,int)"> <!-- --> -</a><a name="callMethod(com.google.protobuf.Descriptors.MethodDescriptor, com.google.protobuf.Message, org.apache.hadoop.hbase.CellScanner, R, org.apache.hadoop.hbase.ipc.MessageConverter, org.apache.hadoop.hbase.ipc.IOExceptionConverter, long, int, org.apache.hadoop.hbase.client.MetricsConnection.CallStats)"> +</a><a name="callMethod(com.google.protobuf.Descriptors.MethodDescriptor, com.google.protobuf.Message, org.apache.hadoop.hbase.CellScanner, R, org.apache.hadoop.hbase.ipc.MessageConverter, org.apache.hadoop.hbase.ipc.IOExceptionConverter, long, int)"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>callMethod</h4> -<pre>public <R extends com.google.protobuf.Message,O> <a href="../../../../../org/apache/hadoop/hbase/client/Future.html" title="interface in org.apache.hadoop.hbase.client">Future</a><O> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.300">callMethod</a>(com.google.protobuf.Descriptors.MethodDescriptor method, +<pre>public <R extends com.google.protobuf.Message,O> <a href="../../../../../org/apache/hadoop/hbase/client/Future.html" title="interface in org.apache.hadoop.hbase.client">Future</a><O> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannelImpl.html#line.299">callMethod</a>(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.Message request, <a href="../../../../../org/apache/hadoop/hbase/CellScanner.html" title="interface in org.apache.hadoop.hbase">CellScanner</a> cellScanner, R responsePrototype, <a href="../../../../../org/apache/hadoop/hbase/ipc/MessageConverter.html" title="interface in org.apache.hadoop.hbase.ipc">MessageConverter</a><R,O> messageConverter, <a href="../../../../../org/apache/hadoop/hbase/ipc/IOExceptionConverter.html" title="interface in org.apache.hadoop.hbase.ipc">IOExceptionConverter</a> exceptionConverter, long rpcTimeout, - int priority, - <a href="../../../../../org/apache/hadoop/hbase/client/MetricsConnection.CallStats.html" title="class in org.apache.hadoop.hbase.client">MetricsConnection.CallStats</a> callStats)</pre> + int priority)</pre> <div class="block">Calls method on channel</div> <dl> <dt><strong>Specified by:</strong></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#callMethod(com.google.protobuf.Descriptors.MethodDescriptor,%20com.google.protobuf.Message,%20org.apache.hadoop.hbase.CellScanner,%20R,%20org.apache.hadoop.hbase.ipc.MessageConverter,%20org.apache.hadoop.hbase.ipc.IOExceptionConverter,%20long,%20int,%20org.apache.hadoop.hbase.client.MetricsConnection.CallStats)">callMethod</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html" title="interface in org.apache.hadoop.hbase.ipc">AsyncRpcChannel</a></code></dd> -<dt><span class="strong">Parameters:</span></dt><dd><code>method</code> - to call</dd><dd><code>request</code> - to send</dd><dd><code>cellScanner</code> - with cells to send</dd><dd><code>responsePrototype</code> - to construct response with</dd><dd><code>rpcTimeout</code> - timeout for request</dd><dd><code>priority</code> - for request</dd><dd><code>messageConverter</code> - for the messages to expected result</dd><dd><code>exceptionConverter</code> - for converting exceptions</dd><dd><code>callStats</code> - collects stats of the call</dd> +<dd><code><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#callMethod(com.google.protobuf.Descriptors.MethodDescriptor,%20com.google.protobuf.Message,%20org.apache.hadoop.hbase.CellScanner,%20R,%20org.apache.hadoop.hbase.ipc.MessageConverter,%20org.apache.hadoop.hbase.ipc.IOExceptionConverter,%20long,%20int)">callMethod</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html" title="interface in org.apache.hadoop.hbase.ipc">AsyncRpcChannel</a></code></dd> +<dt><span class="strong">Parameters:</span></dt><dd><code>method</code> - to call</dd><dd><code>request</code> - to send</dd><dd><code>cellScanner</code> - with cells to send</dd><dd><code>responsePrototype</code> - to construct response with</dd><dd><code>rpcTimeout</code> - timeout for request</dd><dd><code>priority</code> - for request</dd><dd><code>messageConverter</code> - for the messages to expected result</dd><dd><code>exceptionConverter</code> - for converting exceptions</dd> <dt><span class="strong">Returns:</span></dt><dd>Promise for the response Message</dd></dl> </li> </ul>
