http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f30982bd/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 53eb6dc..9fa12cd 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html @@ -96,7 +96,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/AsyncRpcChannel.html#line.82">AsyncRpcChannel</a> +public class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.83">AsyncRpcChannel</a> extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a></pre> <div class="block">Netty RPC channel</div> </li> @@ -212,7 +212,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? </tr> <tr class="altColor"> <td class="colFirst"><code>protected static <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>></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#tokenHandlers">tokenHandlers</a></strong></code> </td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#TOKEN_HANDDLERS">TOKEN_HANDDLERS</a></strong></code> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>(package private) boolean</code></td> @@ -286,58 +286,61 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? </td> </tr> <tr class="altColor"> +<td class="colFirst"><code>private void</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#close0(java.lang.Throwable)">close0</a></strong>(<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)</code> </td> +</tr> +<tr class="rowColor"> <td class="colFirst"><code>private io.netty.channel.ChannelFuture</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#connect(io.netty.bootstrap.Bootstrap)">connect</a></strong>(io.netty.bootstrap.Bootstrap bootstrap)</code> <div class="block">Connect to channel</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#createPreamble(io.netty.buffer.ByteBuf,%20org.apache.hadoop.hbase.security.AuthMethod)">createPreamble</a></strong>(io.netty.buffer.ByteBuf byteBuf, <a href="../../../../../org/apache/hadoop/hbase/security/AuthMethod.html" title="enum in org.apache.hadoop.hbase.security">AuthMethod</a> authMethod)</code> <div class="block">Create connection preamble</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/AsyncRpcChannel.html#equals(java.lang.Object)">equals</a></strong>(<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> obj)</code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#getConnectionHashCode()">getConnectionHashCode</a></strong>()</code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private <a href="../../../../../org/apache/hadoop/hbase/security/SaslClientHandler.html" title="class in org.apache.hadoop.hbase.security">SaslClientHandler</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#getSaslHandler(org.apache.hadoop.security.UserGroupInformation,%20io.netty.bootstrap.Bootstrap)">getSaslHandler</a></strong>(org.apache.hadoop.security.UserGroupInformation realTicket, io.netty.bootstrap.Bootstrap bootstrap)</code> <div class="block">Get SASL handler</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#handleSaslConnectionFailure(int,%20java.lang.Throwable,%20org.apache.hadoop.security.UserGroupInformation)">handleSaslConnectionFailure</a></strong>(int currRetries, <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> ex, org.apache.hadoop.security.UserGroupInformation user)</code> -<div class="block">If multiple clients with the same principal try to connect - to the same server at the same time, the server assumes a - replay attack is in progress.</div> +<div class="block">If multiple clients with the same principal try to connect to the same server at the same time, + the server assumes a replay attack is in progress.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#hashCode()">hashCode</a></strong>()</code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#isAlive()">isAlive</a></strong>()</code> <div class="block">Check if the connection is alive</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>(package private) <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html" title="class in org.apache.hadoop.hbase.ipc">AsyncCall</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#removePendingCall(int)">removePendingCall</a></strong>(int id)</code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#retryOrClose(io.netty.bootstrap.Bootstrap,%20int,%20long,%20java.lang.Throwable)">retryOrClose</a></strong>(io.netty.bootstrap.Bootstrap bootstrap, int failureCount, @@ -346,35 +349,35 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <div class="block">Retry to connect or close</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#setupAuthorization()">setupAuthorization</a></strong>()</code> <div class="block">Set up server authorization</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#shouldAuthenticateOverKrb()">shouldAuthenticateOverKrb</a></strong>()</code> <div class="block">Check if user should authenticate over Kerberos</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#startHBaseConnection(io.netty.channel.Channel)">startHBaseConnection</a></strong>(io.netty.channel.Channel ch)</code> <div class="block">Start HBase connection</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code><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/AsyncRpcChannel.html#toString()">toString</a></strong>()</code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private io.netty.channel.ChannelFuture</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#writeChannelHeader(io.netty.channel.Channel)">writeChannelHeader</a></strong>(io.netty.channel.Channel channel)</code> <div class="block">Write the channel header</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#writeRequest(org.apache.hadoop.hbase.ipc.AsyncCall)">writeRequest</a></strong>(<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html" title="class in org.apache.hadoop.hbase.ipc">AsyncCall</a> call)</code> <div class="block">Write request to channel</div> @@ -408,7 +411,7 @@ extends <a href="http://docs.oracle.com/javase/7/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/AsyncRpcChannel.html#line.83">LOG</a></pre> +<pre>private static final org.apache.commons.logging.Log <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.84">LOG</a></pre> </li> </ul> <a name="MAX_SASL_RETRIES"> @@ -417,17 +420,17 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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/AsyncRpcChannel.html#line.85">MAX_SASL_RETRIES</a></pre> +<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.86">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.AsyncRpcChannel.MAX_SASL_RETRIES">Constant Field Values</a></dd></dl> </li> </ul> -<a name="tokenHandlers"> +<a name="TOKEN_HANDDLERS"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> -<h4>tokenHandlers</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/AsyncRpcChannel.html#line.88">tokenHandlers</a></pre> +<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/AsyncRpcChannel.html#line.88">TOKEN_HANDDLERS</a></pre> </li> </ul> <a name="client"> @@ -436,7 +439,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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/AsyncRpcChannel.html#line.95">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/AsyncRpcChannel.html#line.96">client</a></pre> </li> </ul> <a name="channel"> @@ -445,7 +448,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>channel</h4> -<pre>private io.netty.channel.Channel <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.99">channel</a></pre> +<pre>private io.netty.channel.Channel <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.100">channel</a></pre> </li> </ul> <a name="name"> @@ -454,7 +457,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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/AsyncRpcChannel.html#line.101">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/AsyncRpcChannel.html#line.102">name</a></pre> </li> </ul> <a name="ticket"> @@ -463,7 +466,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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/AsyncRpcChannel.html#line.102">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/AsyncRpcChannel.html#line.103">ticket</a></pre> </li> </ul> <a name="serviceName"> @@ -472,7 +475,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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/AsyncRpcChannel.html#line.103">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/AsyncRpcChannel.html#line.104">serviceName</a></pre> </li> </ul> <a name="address"> @@ -481,7 +484,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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/AsyncRpcChannel.html#line.104">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/AsyncRpcChannel.html#line.105">address</a></pre> </li> </ul> <a name="failureCounter"> @@ -490,7 +493,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>failureCounter</h4> -<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.106">failureCounter</a></pre> +<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.107">failureCounter</a></pre> </li> </ul> <a name="useSasl"> @@ -499,7 +502,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>useSasl</h4> -<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.108">useSasl</a></pre> +<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.109">useSasl</a></pre> </li> </ul> <a name="authMethod"> @@ -508,7 +511,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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/AsyncRpcChannel.html#line.109">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/AsyncRpcChannel.html#line.110">authMethod</a></pre> </li> </ul> <a name="reloginMaxBackoff"> @@ -517,7 +520,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>reloginMaxBackoff</h4> -<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.110">reloginMaxBackoff</a></pre> +<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.111">reloginMaxBackoff</a></pre> </li> </ul> <a name="token"> @@ -526,7 +529,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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/AsyncRpcChannel.html#line.111">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/AsyncRpcChannel.html#line.112">token</a></pre> </li> </ul> <a name="serverPrincipal"> @@ -535,7 +538,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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/AsyncRpcChannel.html#line.112">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/AsyncRpcChannel.html#line.113">serverPrincipal</a></pre> </li> </ul> <a name="pendingCalls"> @@ -597,7 +600,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>AsyncRpcChannel</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.138">AsyncRpcChannel</a>(io.netty.bootstrap.Bootstrap bootstrap, +<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.137">AsyncRpcChannel</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, @@ -620,7 +623,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>connect</h4> -<pre>private io.netty.channel.ChannelFuture <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.161">connect</a>(io.netty.bootstrap.Bootstrap bootstrap)</pre> +<pre>private io.netty.channel.ChannelFuture <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.156">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> @@ -632,7 +635,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>startHBaseConnection</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.215">startHBaseConnection</a>(io.netty.channel.Channel ch)</pre> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.209">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> @@ -643,7 +646,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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/AsyncRpcChannel.html#line.248">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/AsyncRpcChannel.html#line.242">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> @@ -659,7 +662,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>retryOrClose</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.281">retryOrClose</a>(io.netty.bootstrap.Bootstrap bootstrap, +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.275">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> @@ -673,7 +676,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>callMethod</h4> -<pre>public io.netty.util.concurrent.Promise<com.google.protobuf.Message> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.303">callMethod</a>(com.google.protobuf.Descriptors.MethodDescriptor method, +<pre>public io.netty.util.concurrent.Promise<com.google.protobuf.Message> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.297">callMethod</a>(com.google.protobuf.Descriptors.MethodDescriptor method, <a href="../../../../../org/apache/hadoop/hbase/ipc/PayloadCarryingRpcController.html" title="class in org.apache.hadoop.hbase.ipc">PayloadCarryingRpcController</a> controller, com.google.protobuf.Message request, com.google.protobuf.Message responsePrototype, @@ -688,7 +691,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>removePendingCall</h4> -<pre><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/AsyncRpcChannel.html#line.346">removePendingCall</a>(int id)</pre> +<pre><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/AsyncRpcChannel.html#line.337">removePendingCall</a>(int id)</pre> </li> </ul> <a name="writeChannelHeader(io.netty.channel.Channel)"> @@ -697,7 +700,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>writeChannelHeader</h4> -<pre>private io.netty.channel.ChannelFuture <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.359">writeChannelHeader</a>(io.netty.channel.Channel channel) +<pre>private io.netty.channel.ChannelFuture <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.349">writeChannelHeader</a>(io.netty.channel.Channel channel) 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">Write the channel header</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>channel</code> - to write to</dd> @@ -712,7 +715,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>writeRequest</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.394">writeRequest</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html" title="class in org.apache.hadoop.hbase.ipc">AsyncCall</a> call)</pre> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.382">writeRequest</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncCall.html" title="class in org.apache.hadoop.hbase.ipc">AsyncCall</a> call)</pre> <div class="block">Write request to channel</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>call</code> - to write</dd></dl> </li> @@ -723,7 +726,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>setupAuthorization</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.442">setupAuthorization</a>() +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.429">setupAuthorization</a>() 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">Set up server authorization</div> <dl><dt><span class="strong">Throws:</span></dt> @@ -736,7 +739,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>buildUserInfo</h4> -<pre>private org.apache.hadoop.hbase.protobuf.generated.RPCProtos.UserInformation <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.492">buildUserInfo</a>(org.apache.hadoop.security.UserGroupInformation ugi, +<pre>private org.apache.hadoop.hbase.protobuf.generated.RPCProtos.UserInformation <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.478">buildUserInfo</a>(org.apache.hadoop.security.UserGroupInformation ugi, <a href="../../../../../org/apache/hadoop/hbase/security/AuthMethod.html" title="enum in org.apache.hadoop.hbase.security">AuthMethod</a> authMethod)</pre> <div class="block">Build the user information</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>ugi</code> - User Group Information</dd><dd><code>authMethod</code> - Authorization method</dd> @@ -749,19 +752,28 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>createPreamble</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.517">createPreamble</a>(io.netty.buffer.ByteBuf byteBuf, +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.502">createPreamble</a>(io.netty.buffer.ByteBuf byteBuf, <a href="../../../../../org/apache/hadoop/hbase/security/AuthMethod.html" title="enum in org.apache.hadoop.hbase.security">AuthMethod</a> authMethod)</pre> <div class="block">Create connection preamble</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>byteBuf</code> - to write to</dd><dd><code>authMethod</code> - to write</dd></dl> </li> </ul> +<a name="close0(java.lang.Throwable)"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>close0</h4> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.508">close0</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> e)</pre> +</li> +</ul> <a name="close(java.lang.Throwable)"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>close</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.528">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> e)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.549">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> e)</pre> <div class="block">Close connection</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>e</code> - exception on close</dd></dl> </li> @@ -772,7 +784,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>cleanupCalls</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.575">cleanupCalls</a>()</pre> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.568">cleanupCalls</a>()</pre> <div class="block">Clean up calls.</div> </li> </ul> @@ -782,7 +794,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>isAlive</h4> -<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.613">isAlive</a>()</pre> +<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.603">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> @@ -793,7 +805,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>shouldAuthenticateOverKrb</h4> -<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.623">shouldAuthenticateOverKrb</a>() +<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.612">shouldAuthenticateOverKrb</a>() 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">Check if user should authenticate over Kerberos</div> <dl><dt><span class="strong">Returns:</span></dt><dd>true if should be authenticated over Kerberos</dd> @@ -807,26 +819,22 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>handleSaslConnectionFailure</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.660">handleSaslConnectionFailure</a>(int currRetries, +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.643">handleSaslConnectionFailure</a>(int currRetries, <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> ex, org.apache.hadoop.security.UserGroupInformation user) 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>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> -<div class="block">If multiple clients with the same principal try to connect - to the same server at the same time, the server assumes a - replay attack is in progress. This is a feature of kerberos. - In order to work around this, what is done is that the client - backs off randomly and tries to initiate the connection - again. - The other problem is to do with ticket expiry. To handle that, - a relogin is attempted. +<div class="block">If multiple clients with the same principal try to connect to the same server at the same time, + the server assumes a replay attack is in progress. This is a feature of kerberos. In order to + work around this, what is done is that the client backs off randomly and tries to initiate the + connection again. The other problem is to do with ticket expiry. To handle that, a relogin is + attempted. <p> - The retry logic is governed by the <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#shouldAuthenticateOverKrb()"><code>shouldAuthenticateOverKrb()</code></a> - method. In case when the user doesn't have valid credentials, we don't - need to retry (from cache or ticket). In such cases, it is prudent to - throw a runtime exception when we receive a SaslException from the - underlying authentication implementation, so there is no retry from - other high level (for eg, HCM or HBaseAdmin). + The retry logic is governed by the <a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#shouldAuthenticateOverKrb()"><code>shouldAuthenticateOverKrb()</code></a> method. In case when the + user doesn't have valid credentials, we don't need to retry (from cache or ticket). In such + cases, it is prudent to throw a runtime exception when we receive a SaslException from the + underlying authentication implementation, so there is no retry from other high level (for eg, + HCM or HBaseAdmin). </p></div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>currRetries</code> - retry count</dd><dd><code>ex</code> - exception describing fail</dd><dd><code>user</code> - which is trying to connect</dd> <dt><span class="strong">Throws:</span></dt> @@ -840,7 +848,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getConnectionHashCode</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.703">getConnectionHashCode</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.683">getConnectionHashCode</a>()</pre> </li> </ul> <a name="hashCode()"> @@ -849,7 +857,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>hashCode</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.708">hashCode</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.688">hashCode</a>()</pre> <dl> <dt><strong>Overrides:</strong></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#hashCode()" title="class or interface in java.lang">hashCode</a></code> in class <code><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></code></dd> @@ -862,7 +870,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>equals</h4> -<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.713">equals</a>(<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> obj)</pre> +<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html#line.693">equals</a>(<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> obj)</pre> <dl> <dt><strong>Overrides:</strong></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#equals(java.lang.Object)" title="class or interface in java.lang">equals</a></code> in class <code><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></code></dd> @@ -875,7 +883,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockListLast"> <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/AsyncRpcChannel.html#line.723">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/AsyncRpcChannel.html#line.702">toString</a>()</pre> <dl> <dt><strong>Overrides:</strong></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#toString()" title="class or interface in java.lang">toString</a></code> in class <code><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></code></dd>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f30982bd/devapidocs/org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html b/devapidocs/org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html index efc4f5c..5d3af8a 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html @@ -92,6 +92,9 @@ <li>io.netty.channel.ChannelInboundHandlerAdapter</li> <li> <ul class="inheritance"> +<li>io.netty.channel.SimpleChannelInboundHandler<io.netty.buffer.ByteBuf></li> +<li> +<ul class="inheritance"> <li>org.apache.hadoop.hbase.ipc.AsyncServerResponseHandler</li> </ul> </li> @@ -100,6 +103,8 @@ </ul> </li> </ul> +</li> +</ul> <div class="description"> <ul class="blockList"> <li class="blockList"> @@ -111,7 +116,7 @@ <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/AsyncServerResponseHandler.html#line.39">AsyncServerResponseHandler</a> -extends io.netty.channel.ChannelInboundHandlerAdapter</pre> +extends io.netty.channel.SimpleChannelInboundHandler<io.netty.buffer.ByteBuf></pre> <div class="block">Handles Hbase responses</div> </li> </ul> @@ -186,20 +191,36 @@ extends io.netty.channel.ChannelInboundHandlerAdapter</pre> </tr> <tr class="altColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html#channelRead(io.netty.channel.ChannelHandlerContext,%20java.lang.Object)">channelRead</a></strong>(io.netty.channel.ChannelHandlerContext ctx, - <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> msg)</code> </td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html#channelInactive(io.netty.channel.ChannelHandlerContext)">channelInactive</a></strong>(io.netty.channel.ChannelHandlerContext ctx)</code> </td> </tr> <tr class="rowColor"> +<td class="colFirst"><code>protected void</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html#channelRead0(io.netty.channel.ChannelHandlerContext,%20io.netty.buffer.ByteBuf)">channelRead0</a></strong>(io.netty.channel.ChannelHandlerContext ctx, + io.netty.buffer.ByteBuf inBuffer)</code> </td> +</tr> +<tr class="altColor"> <td class="colFirst"><code>private org.apache.hadoop.ipc.RemoteException</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html#createRemoteException(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.ExceptionResponse)">createRemoteException</a></strong>(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.ExceptionResponse e)</code> </td> </tr> +<tr class="rowColor"> +<td class="colFirst"><code>void</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html#exceptionCaught(io.netty.channel.ChannelHandlerContext,%20java.lang.Throwable)">exceptionCaught</a></strong>(io.netty.channel.ChannelHandlerContext ctx, + <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)</code> </td> +</tr> </table> <ul class="blockList"> +<li class="blockList"><a name="methods_inherited_from_class_io.netty.channel.SimpleChannelInboundHandler"> +<!-- --> +</a> +<h3>Methods inherited from class io.netty.channel.SimpleChannelInboundHandler</h3> +<code>acceptInboundMessage, channelRead</code></li> +</ul> +<ul class="blockList"> <li class="blockList"><a name="methods_inherited_from_class_io.netty.channel.ChannelInboundHandlerAdapter"> <!-- --> </a> <h3>Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter</h3> -<code>channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered</code></li> +<code>channelActive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered</code></li> </ul> <ul class="blockList"> <li class="blockList"><a name="methods_inherited_from_class_io.netty.channel.ChannelHandlerAdapter"> @@ -259,7 +280,7 @@ extends io.netty.channel.ChannelInboundHandlerAdapter</pre> <ul class="blockListLast"> <li class="blockList"> <h4>AsyncServerResponseHandler</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html#line.47">AsyncServerResponseHandler</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html" title="class in org.apache.hadoop.hbase.ipc">AsyncRpcChannel</a> channel)</pre> +<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html#line.46">AsyncServerResponseHandler</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncRpcChannel.html" title="class in org.apache.hadoop.hbase.ipc">AsyncRpcChannel</a> channel)</pre> <div class="block">Constructor</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>channel</code> - on which this response handler operates</dd></dl> </li> @@ -272,20 +293,55 @@ extends io.netty.channel.ChannelInboundHandlerAdapter</pre> <!-- --> </a> <h3>Method Detail</h3> -<a name="channelRead(io.netty.channel.ChannelHandlerContext, java.lang.Object)"> +<a name="channelRead0(io.netty.channel.ChannelHandlerContext, io.netty.buffer.ByteBuf)"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>channelRead0</h4> +<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html#line.51">channelRead0</a>(io.netty.channel.ChannelHandlerContext ctx, + io.netty.buffer.ByteBuf inBuffer) + throws <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></pre> +<dl> +<dt><strong>Specified by:</strong></dt> +<dd><code>channelRead0</code> in class <code>io.netty.channel.SimpleChannelInboundHandler<io.netty.buffer.ByteBuf></code></dd> +<dt><span class="strong">Throws:</span></dt> +<dd><code><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></code></dd></dl> +</li> +</ul> +<a name="exceptionCaught(io.netty.channel.ChannelHandlerContext, java.lang.Throwable)"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>exceptionCaught</h4> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html#line.104">exceptionCaught</a>(io.netty.channel.ChannelHandlerContext ctx, + <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) + throws <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></pre> +<dl> +<dt><strong>Specified by:</strong></dt> +<dd><code>exceptionCaught</code> in interface <code>io.netty.channel.ChannelHandler</code></dd> +<dt><strong>Specified by:</strong></dt> +<dd><code>exceptionCaught</code> in interface <code>io.netty.channel.ChannelInboundHandler</code></dd> +<dt><strong>Overrides:</strong></dt> +<dd><code>exceptionCaught</code> in class <code>io.netty.channel.ChannelInboundHandlerAdapter</code></dd> +<dt><span class="strong">Throws:</span></dt> +<dd><code><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></code></dd></dl> +</li> +</ul> +<a name="channelInactive(io.netty.channel.ChannelHandlerContext)"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> -<h4>channelRead</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html#line.51">channelRead</a>(io.netty.channel.ChannelHandlerContext ctx, - <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> msg) - throws <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></pre> +<h4>channelInactive</h4> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html#line.109">channelInactive</a>(io.netty.channel.ChannelHandlerContext ctx) + throws <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></pre> <dl> <dt><strong>Specified by:</strong></dt> -<dd><code>channelRead</code> in interface <code>io.netty.channel.ChannelInboundHandler</code></dd> +<dd><code>channelInactive</code> in interface <code>io.netty.channel.ChannelInboundHandler</code></dd> <dt><strong>Overrides:</strong></dt> -<dd><code>channelRead</code> in class <code>io.netty.channel.ChannelInboundHandlerAdapter</code></dd> +<dd><code>channelInactive</code> in class <code>io.netty.channel.ChannelInboundHandlerAdapter</code></dd> <dt><span class="strong">Throws:</span></dt> <dd><code><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></code></dd></dl> </li> @@ -296,7 +352,7 @@ extends io.netty.channel.ChannelInboundHandlerAdapter</pre> <ul class="blockListLast"> <li class="blockList"> <h4>createRemoteException</h4> -<pre>private org.apache.hadoop.ipc.RemoteException <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html#line.115">createRemoteException</a>(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.ExceptionResponse e)</pre> +<pre>private org.apache.hadoop.ipc.RemoteException <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html#line.117">createRemoteException</a>(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.ExceptionResponse e)</pre> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>e</code> - Proto exception</dd> <dt><span class="strong">Returns:</span></dt><dd>RemoteException made from passed <code>e</code></dd></dl> </li> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f30982bd/devapidocs/org/apache/hadoop/hbase/ipc/package-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/package-tree.html b/devapidocs/org/apache/hadoop/hbase/ipc/package-tree.html index 7cd2152..4e418ac 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/package-tree.html @@ -106,11 +106,15 @@ <ul> <li type="circle">io.netty.channel.ChannelInboundHandlerAdapter (implements io.netty.channel.ChannelInboundHandler) <ul> +<li type="circle">io.netty.channel.SimpleChannelInboundHandler<I> +<ul> <li type="circle">org.apache.hadoop.hbase.ipc.<a href="../../../../../org/apache/hadoop/hbase/ipc/AsyncServerResponseHandler.html" title="class in org.apache.hadoop.hbase.ipc"><span class="strong">AsyncServerResponseHandler</span></a></li> </ul> </li> </ul> </li> +</ul> +</li> <li type="circle">org.apache.hadoop.hbase.ipc.<a href="../../../../../org/apache/hadoop/hbase/ipc/ConnectionId.html" title="class in org.apache.hadoop.hbase.ipc"><span class="strong">ConnectionId</span></a></li> <li type="circle">org.apache.hadoop.hbase.ipc.<a href="../../../../../org/apache/hadoop/hbase/ipc/CoprocessorRpcChannel.html" title="class in org.apache.hadoop.hbase.ipc"><span class="strong">CoprocessorRpcChannel</span></a> (implements com.google.protobuf.BlockingRpcChannel, com.google.protobuf.RpcChannel) <ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f30982bd/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html b/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html index 482ecc3..fe5a467 100644 --- a/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html @@ -268,9 +268,9 @@ <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.mapreduce.<a href="../../../../../org/apache/hadoop/hbase/mapreduce/RowCounter.RowCounterMapper.Counters.html" title="enum in org.apache.hadoop.hbase.mapreduce"><span class="strong">RowCounter.RowCounterMapper.Counters</span></a></li> -<li type="circle">org.apache.hadoop.hbase.mapreduce.<a href="../../../../../org/apache/hadoop/hbase/mapreduce/SyncTable.SyncMapper.Counter.html" title="enum in org.apache.hadoop.hbase.mapreduce"><span class="strong">SyncTable.SyncMapper.Counter</span></a></li> -<li type="circle">org.apache.hadoop.hbase.mapreduce.<a href="../../../../../org/apache/hadoop/hbase/mapreduce/CellCounter.CellCounterMapper.Counters.html" title="enum in org.apache.hadoop.hbase.mapreduce"><span class="strong">CellCounter.CellCounterMapper.Counters</span></a></li> <li type="circle">org.apache.hadoop.hbase.mapreduce.<a href="../../../../../org/apache/hadoop/hbase/mapreduce/TableSplit.Version.html" title="enum in org.apache.hadoop.hbase.mapreduce"><span class="strong">TableSplit.Version</span></a></li> +<li type="circle">org.apache.hadoop.hbase.mapreduce.<a href="../../../../../org/apache/hadoop/hbase/mapreduce/CellCounter.CellCounterMapper.Counters.html" title="enum in org.apache.hadoop.hbase.mapreduce"><span class="strong">CellCounter.CellCounterMapper.Counters</span></a></li> +<li type="circle">org.apache.hadoop.hbase.mapreduce.<a href="../../../../../org/apache/hadoop/hbase/mapreduce/SyncTable.SyncMapper.Counter.html" title="enum in org.apache.hadoop.hbase.mapreduce"><span class="strong">SyncTable.SyncMapper.Counter</span></a></li> </ul> </li> </ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f30982bd/devapidocs/org/apache/hadoop/hbase/master/package-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/master/package-tree.html b/devapidocs/org/apache/hadoop/hbase/master/package-tree.html index 7984197..4f93c9c 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/master/package-tree.html @@ -318,10 +318,10 @@ <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.master.<a href="../../../../../org/apache/hadoop/hbase/master/RegionState.State.html" title="enum in org.apache.hadoop.hbase.master"><span class="strong">RegionState.State</span></a></li> -<li type="circle">org.apache.hadoop.hbase.master.<a href="../../../../../org/apache/hadoop/hbase/master/SplitLogManager.TerminationStatus.html" title="enum in org.apache.hadoop.hbase.master"><span class="strong">SplitLogManager.TerminationStatus</span></a></li> <li type="circle">org.apache.hadoop.hbase.master.<a href="../../../../../org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html" title="enum in org.apache.hadoop.hbase.master"><span class="strong">MasterRpcServices.BalanceSwitchMode</span></a></li> <li type="circle">org.apache.hadoop.hbase.master.<a href="../../../../../org/apache/hadoop/hbase/master/MetricsMasterSourceFactoryImpl.FactoryStorage.html" title="enum in org.apache.hadoop.hbase.master"><span class="strong">MetricsMasterSourceFactoryImpl.FactoryStorage</span></a></li> +<li type="circle">org.apache.hadoop.hbase.master.<a href="../../../../../org/apache/hadoop/hbase/master/RegionState.State.html" title="enum in org.apache.hadoop.hbase.master"><span class="strong">RegionState.State</span></a></li> +<li type="circle">org.apache.hadoop.hbase.master.<a href="../../../../../org/apache/hadoop/hbase/master/SplitLogManager.TerminationStatus.html" title="enum in org.apache.hadoop.hbase.master"><span class="strong">SplitLogManager.TerminationStatus</span></a></li> <li type="circle">org.apache.hadoop.hbase.master.<a href="../../../../../org/apache/hadoop/hbase/master/SplitLogManager.ResubmitDirective.html" title="enum in org.apache.hadoop.hbase.master"><span class="strong">SplitLogManager.ResubmitDirective</span></a></li> </ul> </li> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f30982bd/devapidocs/org/apache/hadoop/hbase/master/procedure/package-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/master/procedure/package-tree.html b/devapidocs/org/apache/hadoop/hbase/master/procedure/package-tree.html index a0a1bcc..aaf26d9 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/procedure/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/master/procedure/package-tree.html @@ -145,9 +145,9 @@ <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.master.procedure.<a href="../../../../../../org/apache/hadoop/hbase/master/procedure/ServerProcedureInterface.ServerOperationType.html" title="enum in org.apache.hadoop.hbase.master.procedure"><span class="strong">ServerProcedureInterface.ServerOperationType</span></a></li> <li type="circle">org.apache.hadoop.hbase.master.procedure.<a href="../../../../../../org/apache/hadoop/hbase/master/procedure/DisableTableProcedure.MarkRegionOfflineOpResult.html" title="enum in org.apache.hadoop.hbase.master.procedure"><span class="strong">DisableTableProcedure.MarkRegionOfflineOpResult</span></a></li> <li type="circle">org.apache.hadoop.hbase.master.procedure.<a href="../../../../../../org/apache/hadoop/hbase/master/procedure/TableProcedureInterface.TableOperationType.html" title="enum in org.apache.hadoop.hbase.master.procedure"><span class="strong">TableProcedureInterface.TableOperationType</span></a></li> +<li type="circle">org.apache.hadoop.hbase.master.procedure.<a href="../../../../../../org/apache/hadoop/hbase/master/procedure/ServerProcedureInterface.ServerOperationType.html" title="enum in org.apache.hadoop.hbase.master.procedure"><span class="strong">ServerProcedureInterface.ServerOperationType</span></a></li> </ul> </li> </ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f30982bd/devapidocs/org/apache/hadoop/hbase/package-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/package-tree.html b/devapidocs/org/apache/hadoop/hbase/package-tree.html index 11c70f1..3094708 100644 --- a/devapidocs/org/apache/hadoop/hbase/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/package-tree.html @@ -361,14 +361,14 @@ <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.<a href="../../../../org/apache/hadoop/hbase/CompatibilitySingletonFactory.SingletonStorage.html" title="enum in org.apache.hadoop.hbase"><span class="strong">CompatibilitySingletonFactory.SingletonStorage</span></a></li> <li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/Coprocessor.State.html" title="enum in org.apache.hadoop.hbase"><span class="strong">Coprocessor.State</span></a></li> -<li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/HConstants.Modify.html" title="enum in org.apache.hadoop.hbase"><span class="strong">HConstants.Modify</span></a></li> +<li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/HConstants.OperationStatusCode.html" title="enum in org.apache.hadoop.hbase"><span class="strong">HConstants.OperationStatusCode</span></a></li> <li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/MetaTableAccessor.QueryType.html" title="enum in org.apache.hadoop.hbase"><span class="strong">MetaTableAccessor.QueryType</span></a></li> +<li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/HConstants.Modify.html" title="enum in org.apache.hadoop.hbase"><span class="strong">HConstants.Modify</span></a></li> <li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/HealthChecker.HealthCheckerExitStatus.html" title="enum in org.apache.hadoop.hbase"><span class="strong">HealthChecker.HealthCheckerExitStatus</span></a></li> -<li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/HConstants.OperationStatusCode.html" title="enum in org.apache.hadoop.hbase"><span class="strong">HConstants.OperationStatusCode</span></a></li> -<li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/KeyValue.Type.html" title="enum in org.apache.hadoop.hbase"><span class="strong">KeyValue.Type</span></a></li> <li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/KeepDeletedCells.html" title="enum in org.apache.hadoop.hbase"><span class="strong">KeepDeletedCells</span></a></li> +<li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/CompatibilitySingletonFactory.SingletonStorage.html" title="enum in org.apache.hadoop.hbase"><span class="strong">CompatibilitySingletonFactory.SingletonStorage</span></a></li> +<li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/KeyValue.Type.html" title="enum in org.apache.hadoop.hbase"><span class="strong">KeyValue.Type</span></a></li> </ul> </li> </ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f30982bd/devapidocs/org/apache/hadoop/hbase/quotas/package-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/quotas/package-tree.html b/devapidocs/org/apache/hadoop/hbase/quotas/package-tree.html index 667ab2a..7e204c8 100644 --- a/devapidocs/org/apache/hadoop/hbase/quotas/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/quotas/package-tree.html @@ -173,8 +173,8 @@ <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.quotas.<a href="../../../../../org/apache/hadoop/hbase/quotas/QuotaType.html" title="enum in org.apache.hadoop.hbase.quotas"><span class="strong">QuotaType</span></a></li> -<li type="circle">org.apache.hadoop.hbase.quotas.<a href="../../../../../org/apache/hadoop/hbase/quotas/ThrottleType.html" title="enum in org.apache.hadoop.hbase.quotas"><span class="strong">ThrottleType</span></a></li> <li type="circle">org.apache.hadoop.hbase.quotas.<a href="../../../../../org/apache/hadoop/hbase/quotas/OperationQuota.OperationType.html" title="enum in org.apache.hadoop.hbase.quotas"><span class="strong">OperationQuota.OperationType</span></a></li> +<li type="circle">org.apache.hadoop.hbase.quotas.<a href="../../../../../org/apache/hadoop/hbase/quotas/ThrottleType.html" title="enum in org.apache.hadoop.hbase.quotas"><span class="strong">ThrottleType</span></a></li> <li type="circle">org.apache.hadoop.hbase.quotas.<a href="../../../../../org/apache/hadoop/hbase/quotas/QuotaScope.html" title="enum in org.apache.hadoop.hbase.quotas"><span class="strong">QuotaScope</span></a></li> <li type="circle">org.apache.hadoop.hbase.quotas.<a href="../../../../../org/apache/hadoop/hbase/quotas/ThrottlingException.Type.html" title="enum in org.apache.hadoop.hbase.quotas"><span class="strong">ThrottlingException.Type</span></a></li> </ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f30982bd/devapidocs/org/apache/hadoop/hbase/regionserver/KeyValueHeap.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/KeyValueHeap.html b/devapidocs/org/apache/hadoop/hbase/regionserver/KeyValueHeap.html index 1c09727..e8c7db0 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/KeyValueHeap.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/KeyValueHeap.html @@ -713,8 +713,9 @@ implements <a href="../../../../../org/apache/hadoop/hbase/regionserver/KeyValue <dd><code><a href="../../../../../org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#getNextIndexedKey()">getNextIndexedKey</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/regionserver/KeyValueScanner.html" title="interface in org.apache.hadoop.hbase.regionserver">KeyValueScanner</a></code></dd> <dt><strong>Overrides:</strong></dt> <dd><code><a href="../../../../../org/apache/hadoop/hbase/regionserver/NonLazyKeyValueScanner.html#getNextIndexedKey()">getNextIndexedKey</a></code> in class <code><a href="../../../../../org/apache/hadoop/hbase/regionserver/NonLazyKeyValueScanner.html" title="class in org.apache.hadoop.hbase.regionserver">NonLazyKeyValueScanner</a></code></dd> -<dt><span class="strong">Returns:</span></dt><dd>the next key in the index (the key to seek to the next block) - if known, or null otherwise</dd></dl> +<dt><span class="strong">Returns:</span></dt><dd>the next key in the index, usually the first key of next block OR a key that falls + between last key of current block and first key of next block.. + see HFileWriterImpl#getMidpoint, or null if not known.</dd></dl> </li> </ul> <a name="shipped()"> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f30982bd/devapidocs/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html b/devapidocs/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html index 478664e..3af75a7 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html @@ -96,7 +96,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 interface <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.33">KeyValueScanner</a> +public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.36">KeyValueScanner</a> extends <a href="../../../../../org/apache/hadoop/hbase/regionserver/Shipper.html" title="interface in org.apache.hadoop.hbase.regionserver">Shipper</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html?is-external=true"; title="class or interface in java.io">Closeable</a></pre> <div class="block">Scanner that returns the next KeyValue.</div> </li> @@ -268,7 +268,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/regionserver/Shipper.htm <ul class="blockListLast"> <li class="blockList"> <h4>NO_NEXT_INDEXED_KEY</h4> -<pre>static final <a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.38">NO_NEXT_INDEXED_KEY</a></pre> +<pre>static final <a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.41">NO_NEXT_INDEXED_KEY</a></pre> <div class="block">The byte array represents for NO_NEXT_INDEXED_KEY; The actual value is irrelevant because this is always compared by reference.</div> </li> @@ -287,7 +287,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/regionserver/Shipper.htm <ul class="blockList"> <li class="blockList"> <h4>peek</h4> -<pre><a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.44">peek</a>()</pre> +<pre><a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.47">peek</a>()</pre> <div class="block">Look at the next Cell in this scanner, but do not iterate scanner.</div> <dl><dt><span class="strong">Returns:</span></dt><dd>the next Cell</dd></dl> </li> @@ -298,7 +298,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/regionserver/Shipper.htm <ul class="blockList"> <li class="blockList"> <h4>next</h4> -<pre><a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.50">next</a>() +<pre><a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.53">next</a>() 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">Return the next Cell in this scanner, iterating the scanner</div> <dl><dt><span class="strong">Returns:</span></dt><dd>the next Cell</dd> @@ -312,7 +312,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/regionserver/Shipper.htm <ul class="blockList"> <li class="blockList"> <h4>seek</h4> -<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.57">seek</a>(<a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> key) +<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.60">seek</a>(<a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> key) 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">Seek the scanner at or after the specified KeyValue.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>key</code> - seek value</dd> @@ -327,7 +327,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/regionserver/Shipper.htm <ul class="blockList"> <li class="blockList"> <h4>reseek</h4> -<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.67">reseek</a>(<a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> key) +<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.70">reseek</a>(<a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> key) 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">Reseek the scanner at or after the specified KeyValue. This method is guaranteed to seek at or after the required key only if the @@ -345,7 +345,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/regionserver/Shipper.htm <ul class="blockList"> <li class="blockList"> <h4>getSequenceID</h4> -<pre>long <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.76">getSequenceID</a>()</pre> +<pre>long <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.79">getSequenceID</a>()</pre> <div class="block">Get the sequence id associated with this KeyValueScanner. This is required for comparing multiple files to find out which one has the latest data. The default implementation for this would be to return 0. A file having @@ -358,7 +358,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/regionserver/Shipper.htm <ul class="blockList"> <li class="blockList"> <h4>close</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.81">close</a>()</pre> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.84">close</a>()</pre> <div class="block">Close the KeyValue scanner.</div> <dl> <dt><strong>Specified by:</strong></dt> @@ -374,7 +374,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/regionserver/Shipper.htm <ul class="blockList"> <li class="blockList"> <h4>shouldUseScanner</h4> -<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.92">shouldUseScanner</a>(<a href="../../../../../org/apache/hadoop/hbase/client/Scan.html" title="class in org.apache.hadoop.hbase.client">Scan</a> scan, +<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.95">shouldUseScanner</a>(<a href="../../../../../org/apache/hadoop/hbase/client/Scan.html" title="class in org.apache.hadoop.hbase.client">Scan</a> scan, <a href="../../../../../org/apache/hadoop/hbase/regionserver/Store.html" title="interface in org.apache.hadoop.hbase.regionserver">Store</a> store, long oldestUnexpiredTS)</pre> <div class="block">Allows to filter out scanners (both StoreFile and memstore) that we don't @@ -390,7 +390,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/regionserver/Shipper.htm <ul class="blockList"> <li class="blockList"> <h4>requestSeek</h4> -<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.106">requestSeek</a>(<a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> kv, +<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.109">requestSeek</a>(<a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> kv, boolean forward, boolean useBloom) 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> @@ -411,7 +411,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/regionserver/Shipper.htm <ul class="blockList"> <li class="blockList"> <h4>realSeekDone</h4> -<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.115">realSeekDone</a>()</pre> +<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.118">realSeekDone</a>()</pre> <div class="block">We optimize our store scanners by checking the most recent store file first, so we sometimes pretend we have done a seek but delay it until the store scanner bubbles up to the top of the key-value heap. This method is @@ -424,7 +424,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/regionserver/Shipper.htm <ul class="blockList"> <li class="blockList"> <h4>enforceSeek</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.124">enforceSeek</a>() +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.127">enforceSeek</a>() 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">Does the real seek operation in case it was skipped by seekToRowCol(KeyValue, boolean) (TODO: Whats this?). Note that this function should @@ -441,7 +441,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/regionserver/Shipper.htm <ul class="blockList"> <li class="blockList"> <h4>isFileScanner</h4> -<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.130">isFileScanner</a>()</pre> +<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.133">isFileScanner</a>()</pre> <dl><dt><span class="strong">Returns:</span></dt><dd>true if this is a file scanner. Otherwise a memory scanner is assumed.</dd></dl> </li> @@ -452,7 +452,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/regionserver/Shipper.htm <ul class="blockList"> <li class="blockList"> <h4>backwardSeek</h4> -<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.145">backwardSeek</a>(<a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> key) +<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.148">backwardSeek</a>(<a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> key) 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">Seek the scanner at or before the row of specified Cell, it firstly tries to seek the scanner at or after the specified Cell, return if @@ -472,7 +472,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/regionserver/Shipper.htm <ul class="blockList"> <li class="blockList"> <h4>seekToPreviousRow</h4> -<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.154">seekToPreviousRow</a>(<a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> key) +<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.157">seekToPreviousRow</a>(<a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> key) 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">Seek the scanner at the first Cell of the row which is the previous row of specified key</div> @@ -489,7 +489,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/regionserver/Shipper.htm <ul class="blockList"> <li class="blockList"> <h4>seekToLastRow</h4> -<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.163">seekToLastRow</a>() +<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.166">seekToLastRow</a>() 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">Seek the scanner at the first KeyValue of last row</div> <dl><dt><span class="strong">Returns:</span></dt><dd>true if scanner has values left, false if the underlying data is @@ -504,9 +504,10 @@ extends <a href="../../../../../org/apache/hadoop/hbase/regionserver/Shipper.htm <ul class="blockListLast"> <li class="blockList"> <h4>getNextIndexedKey</h4> -<pre><a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.169">getNextIndexedKey</a>()</pre> -<dl><dt><span class="strong">Returns:</span></dt><dd>the next key in the index (the key to seek to the next block) - if known, or null otherwise</dd></dl> +<pre><a href="../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/KeyValueScanner.html#line.173">getNextIndexedKey</a>()</pre> +<dl><dt><span class="strong">Returns:</span></dt><dd>the next key in the index, usually the first key of next block OR a key that falls + between last key of current block and first key of next block.. + see HFileWriterImpl#getMidpoint, or null if not known.</dd></dl> </li> </ul> </li>
