http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/org/apache/hadoop/hbase/thrift/DemoClient.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/thrift/DemoClient.html b/devapidocs/org/apache/hadoop/hbase/thrift/DemoClient.html index a81ad06..472ba0e 100644 --- a/devapidocs/org/apache/hadoop/hbase/thrift/DemoClient.html +++ b/devapidocs/org/apache/hadoop/hbase/thrift/DemoClient.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":9,"i2":9,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10}; +var methods = {"i0":10,"i1":9,"i2":9,"i3":9,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10}; var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -146,6 +146,10 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <td class="colFirst"><code>private static boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/thrift/DemoClient.html#secure">secure</a></span></code> </td> </tr> +<tr class="altColor"> +<td class="colFirst"><code>private static <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/thrift/DemoClient.html#serverPrincipal">serverPrincipal</a></span></code> </td> +</tr> </table> </li> </ul> @@ -187,27 +191,31 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/thrift/DemoClient.html#getSubject--">getSubject</a></span>()</code> </td> </tr> <tr id="i2" class="altColor"> +<td class="colFirst"><code>private static boolean</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/thrift/DemoClient.html#isBoolean-java.lang.String-">isBoolean</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> s)</code> </td> +</tr> +<tr id="i3" class="rowColor"> <td class="colFirst"><code>static void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/thrift/DemoClient.html#main-java.lang.String:A-">main</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>[] args)</code> </td> </tr> -<tr id="i3" class="rowColor"> +<tr id="i4" class="altColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/thrift/DemoClient.html#printRow-java.util.List-">printRow</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.hbase.thrift.generated.TRowResult> rows)</code> </td> </tr> -<tr id="i4" class="altColor"> +<tr id="i5" class="rowColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/thrift/DemoClient.html#printRow-org.apache.hadoop.hbase.thrift.generated.TRowResult-">printRow</a></span>(org.apache.hadoop.hbase.thrift.generated.TRowResult rowResult)</code> </td> </tr> -<tr id="i5" class="rowColor"> +<tr id="i6" class="altColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/thrift/DemoClient.html#printVersions-java.nio.ByteBuffer-java.util.List-">printVersions</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true"; title="class or interface in java.nio">ByteBuffer</a> row, <a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.hbase.thrift.generated.TCell> versions)</code> </td> </tr> -<tr id="i6" class="altColor"> +<tr id="i7" class="rowColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/thrift/DemoClient.html#run--">run</a></span>()</code> </td> </tr> -<tr id="i7" class="rowColor"> +<tr id="i8" class="altColor"> <td class="colFirst"><code>private <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/thrift/DemoClient.html#utf8-byte:A-">utf8</a></span>(byte[] buf)</code> </td> </tr> @@ -263,12 +271,21 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <a name="secure"> <!-- --> </a> -<ul class="blockListLast"> +<ul class="blockList"> <li class="blockList"> <h4>secure</h4> <pre>private static boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.62">secure</a></pre> </li> </ul> +<a name="serverPrincipal"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>serverPrincipal</h4> +<pre>private static <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.63">serverPrincipal</a></pre> +</li> +</ul> </li> </ul> <!-- ========= CONSTRUCTOR DETAIL ======== --> @@ -283,7 +300,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>DemoClient</h4> -<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.91">DemoClient</a>()</pre> +<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.100">DemoClient</a>()</pre> </li> </ul> </li> @@ -300,7 +317,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>main</h4> -<pre>public static void <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.64">main</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>[] args) +<pre>public static void <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.65">main</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>[] args) throws <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -308,13 +325,22 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? </dl> </li> </ul> +<a name="isBoolean-java.lang.String-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>isBoolean</h4> +<pre>private static boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.96">isBoolean</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> s)</pre> +</li> +</ul> <a name="utf8-byte:A-"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>utf8</h4> -<pre>private <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.96">utf8</a>(byte[] buf)</pre> +<pre>private <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.105">utf8</a>(byte[] buf)</pre> </li> </ul> <a name="bytes-java.lang.String-"> @@ -323,7 +349,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>bytes</h4> -<pre>private byte[] <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.105">bytes</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> s)</pre> +<pre>private byte[] <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.114">bytes</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> s)</pre> </li> </ul> <a name="run--"> @@ -332,7 +358,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>run</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.114">run</a>() +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.123">run</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -346,7 +372,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>printVersions</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.338">printVersions</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true"; title="class or interface in java.nio">ByteBuffer</a> row, +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.347">printVersions</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true"; title="class or interface in java.nio">ByteBuffer</a> row, <a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.hbase.thrift.generated.TCell> versions)</pre> </li> </ul> @@ -356,7 +382,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>printRow</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.347">printRow</a>(org.apache.hadoop.hbase.thrift.generated.TRowResult rowResult)</pre> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.356">printRow</a>(org.apache.hadoop.hbase.thrift.generated.TRowResult rowResult)</pre> </li> </ul> <a name="printRow-java.util.List-"> @@ -365,7 +391,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>printRow</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.365">printRow</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.hbase.thrift.generated.TRowResult> rows)</pre> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.374">printRow</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.hbase.thrift.generated.TRowResult> rows)</pre> </li> </ul> <a name="getSubject--"> @@ -374,7 +400,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>getSubject</h4> -<pre>static <a href="http://docs.oracle.com/javase/8/docs/api/javax/security/auth/Subject.html?is-external=true"; title="class or interface in javax.security.auth">Subject</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.371">getSubject</a>() +<pre>static <a href="http://docs.oracle.com/javase/8/docs/api/javax/security/auth/Subject.html?is-external=true"; title="class or interface in javax.security.auth">Subject</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/thrift/DemoClient.html#line.380">getSubject</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/org/apache/hadoop/hbase/thrift/package-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/thrift/package-tree.html b/devapidocs/org/apache/hadoop/hbase/thrift/package-tree.html index 570c4fa..cd08056 100644 --- a/devapidocs/org/apache/hadoop/hbase/thrift/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/thrift/package-tree.html @@ -198,9 +198,9 @@ <ul> <li type="circle">java.lang.<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true"; title="class or interface in java.lang"><span class="typeNameLink">Enum</span></a><E> (implements java.lang.<a href="http://docs.oracle.com/javase/8/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/8/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.thrift.<a href="../../../../../org/apache/hadoop/hbase/thrift/ThriftMetrics.ThriftServerType.html" title="enum in org.apache.hadoop.hbase.thrift"><span class="typeNameLink">ThriftMetrics.ThriftServerType</span></a></li> <li type="circle">org.apache.hadoop.hbase.thrift.<a href="../../../../../org/apache/hadoop/hbase/thrift/ThriftServerRunner.ImplType.html" title="enum in org.apache.hadoop.hbase.thrift"><span class="typeNameLink">ThriftServerRunner.ImplType</span></a></li> <li type="circle">org.apache.hadoop.hbase.thrift.<a href="../../../../../org/apache/hadoop/hbase/thrift/MetricsThriftServerSourceFactoryImpl.FactoryStorage.html" title="enum in org.apache.hadoop.hbase.thrift"><span class="typeNameLink">MetricsThriftServerSourceFactoryImpl.FactoryStorage</span></a></li> +<li type="circle">org.apache.hadoop.hbase.thrift.<a href="../../../../../org/apache/hadoop/hbase/thrift/ThriftMetrics.ThriftServerType.html" title="enum in org.apache.hadoop.hbase.thrift"><span class="typeNameLink">ThriftMetrics.ThriftServerType</span></a></li> </ul> </li> </ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/org/apache/hadoop/hbase/util/package-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/util/package-tree.html b/devapidocs/org/apache/hadoop/hbase/util/package-tree.html index f5b4052..d8c46f3 100644 --- a/devapidocs/org/apache/hadoop/hbase/util/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/util/package-tree.html @@ -522,14 +522,14 @@ <ul> <li type="circle">java.lang.<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true"; title="class or interface in java.lang"><span class="typeNameLink">Enum</span></a><E> (implements java.lang.<a href="http://docs.oracle.com/javase/8/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/8/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.util.<a href="../../../../../org/apache/hadoop/hbase/util/HBaseFsck.ErrorReporter.ERROR_CODE.html" title="enum in org.apache.hadoop.hbase.util"><span class="typeNameLink">HBaseFsck.ErrorReporter.ERROR_CODE</span></a></li> <li type="circle">org.apache.hadoop.hbase.util.<a href="../../../../../org/apache/hadoop/hbase/util/Bytes.LexicographicalComparerHolder.PureJavaComparer.html" title="enum in org.apache.hadoop.hbase.util"><span class="typeNameLink">Bytes.LexicographicalComparerHolder.PureJavaComparer</span></a> (implements org.apache.hadoop.hbase.util.<a href="../../../../../org/apache/hadoop/hbase/util/Bytes.Comparer.html" title="interface in org.apache.hadoop.hbase.util">Bytes.Comparer</a><T>)</li> -<li type="circle">org.apache.hadoop.hbase.util.<a href="../../../../../org/apache/hadoop/hbase/util/ChecksumType.html" title="enum in org.apache.hadoop.hbase.util"><span class="typeNameLink">ChecksumType</span></a></li> +<li type="circle">org.apache.hadoop.hbase.util.<a href="../../../../../org/apache/hadoop/hbase/util/PrettyPrinter.Unit.html" title="enum in org.apache.hadoop.hbase.util"><span class="typeNameLink">PrettyPrinter.Unit</span></a></li> <li type="circle">org.apache.hadoop.hbase.util.<a href="../../../../../org/apache/hadoop/hbase/util/PoolMap.PoolType.html" title="enum in org.apache.hadoop.hbase.util"><span class="typeNameLink">PoolMap.PoolType</span></a></li> <li type="circle">org.apache.hadoop.hbase.util.<a href="../../../../../org/apache/hadoop/hbase/util/Order.html" title="enum in org.apache.hadoop.hbase.util"><span class="typeNameLink">Order</span></a></li> -<li type="circle">org.apache.hadoop.hbase.util.<a href="../../../../../org/apache/hadoop/hbase/util/IdReadWriteLock.ReferenceType.html" title="enum in org.apache.hadoop.hbase.util"><span class="typeNameLink">IdReadWriteLock.ReferenceType</span></a></li> <li type="circle">org.apache.hadoop.hbase.util.<a href="../../../../../org/apache/hadoop/hbase/util/Bytes.LexicographicalComparerHolder.UnsafeComparer.html" title="enum in org.apache.hadoop.hbase.util"><span class="typeNameLink">Bytes.LexicographicalComparerHolder.UnsafeComparer</span></a> (implements org.apache.hadoop.hbase.util.<a href="../../../../../org/apache/hadoop/hbase/util/Bytes.Comparer.html" title="interface in org.apache.hadoop.hbase.util">Bytes.Comparer</a><T>)</li> -<li type="circle">org.apache.hadoop.hbase.util.<a href="../../../../../org/apache/hadoop/hbase/util/PrettyPrinter.Unit.html" title="enum in org.apache.hadoop.hbase.util"><span class="typeNameLink">PrettyPrinter.Unit</span></a></li> -<li type="circle">org.apache.hadoop.hbase.util.<a href="../../../../../org/apache/hadoop/hbase/util/HBaseFsck.ErrorReporter.ERROR_CODE.html" title="enum in org.apache.hadoop.hbase.util"><span class="typeNameLink">HBaseFsck.ErrorReporter.ERROR_CODE</span></a></li> +<li type="circle">org.apache.hadoop.hbase.util.<a href="../../../../../org/apache/hadoop/hbase/util/IdReadWriteLock.ReferenceType.html" title="enum in org.apache.hadoop.hbase.util"><span class="typeNameLink">IdReadWriteLock.ReferenceType</span></a></li> +<li type="circle">org.apache.hadoop.hbase.util.<a href="../../../../../org/apache/hadoop/hbase/util/ChecksumType.html" title="enum in org.apache.hadoop.hbase.util"><span class="typeNameLink">ChecksumType</span></a></li> </ul> </li> </ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/org/apache/hadoop/hbase/wal/package-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/wal/package-tree.html b/devapidocs/org/apache/hadoop/hbase/wal/package-tree.html index 3ded3f7..ef802fb 100644 --- a/devapidocs/org/apache/hadoop/hbase/wal/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/wal/package-tree.html @@ -167,8 +167,8 @@ <ul> <li type="circle">java.lang.<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true"; title="class or interface in java.lang"><span class="typeNameLink">Enum</span></a><E> (implements java.lang.<a href="http://docs.oracle.com/javase/8/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/8/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.wal.<a href="../../../../../org/apache/hadoop/hbase/wal/WALFactory.Providers.html" title="enum in org.apache.hadoop.hbase.wal"><span class="typeNameLink">WALFactory.Providers</span></a></li> <li type="circle">org.apache.hadoop.hbase.wal.<a href="../../../../../org/apache/hadoop/hbase/wal/RegionGroupingProvider.Strategies.html" title="enum in org.apache.hadoop.hbase.wal"><span class="typeNameLink">RegionGroupingProvider.Strategies</span></a></li> +<li type="circle">org.apache.hadoop.hbase.wal.<a href="../../../../../org/apache/hadoop/hbase/wal/WALFactory.Providers.html" title="enum in org.apache.hadoop.hbase.wal"><span class="typeNameLink">WALFactory.Providers</span></a></li> </ul> </li> </ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/src-html/org/apache/hadoop/hbase/Version.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/Version.html b/devapidocs/src-html/org/apache/hadoop/hbase/Version.html index 7e38ea3..61d7005 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/Version.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/Version.html @@ -16,11 +16,11 @@ <span class="sourceLineNo">008</span>@InterfaceAudience.Private<a name="line.8"></a> <span class="sourceLineNo">009</span>public class Version {<a name="line.9"></a> <span class="sourceLineNo">010</span> public static final String version = "3.0.0-SNAPSHOT";<a name="line.10"></a> -<span class="sourceLineNo">011</span> public static final String revision = "6114824b53c1299d2d79572800fb1e1cbc96cb66";<a name="line.11"></a> +<span class="sourceLineNo">011</span> public static final String revision = "043ec9b37e43328e8784f88e3d6867b007a31d1d";<a name="line.11"></a> <span class="sourceLineNo">012</span> public static final String user = "jenkins";<a name="line.12"></a> -<span class="sourceLineNo">013</span> public static final String date = "Thu Aug 10 22:04:05 UTC 2017";<a name="line.13"></a> +<span class="sourceLineNo">013</span> public static final String date = "Fri Aug 11 14:40:23 UTC 2017";<a name="line.13"></a> <span class="sourceLineNo">014</span> public static final String url = "git://asf920.gq1.ygridcore.net/home/jenkins/jenkins-slave/workspace/hbase_generate_website/hbase";<a name="line.14"></a> -<span class="sourceLineNo">015</span> public static final String srcChecksum = "9e3fa0f1ca1a122ae35a8e67fc4f67ef";<a name="line.15"></a> +<span class="sourceLineNo">015</span> public static final String srcChecksum = "ea21724ef60501efdfac991680f85c00";<a name="line.15"></a> <span class="sourceLineNo">016</span>}<a name="line.16"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.QueueRowAccess.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.QueueRowAccess.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.QueueRowAccess.html index 216bf8d..7c8ee35 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.QueueRowAccess.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.QueueRowAccess.html @@ -313,117 +313,98 @@ <span class="sourceLineNo">305</span> }<a name="line.305"></a> <span class="sourceLineNo">306</span> };<a name="line.306"></a> <span class="sourceLineNo">307</span> }<a name="line.307"></a> -<span class="sourceLineNo">308</span> /**<a name="line.308"></a> -<span class="sourceLineNo">309</span> * This is used for legacy purposes in {@link HTable#setWriteBufferSize(long)} only. This ought<a name="line.309"></a> -<span class="sourceLineNo">310</span> * not be called for production uses.<a name="line.310"></a> -<span class="sourceLineNo">311</span> * If the new buffer size is smaller than the stored data, the {@link BufferedMutatorImpl#flush()}<a name="line.311"></a> -<span class="sourceLineNo">312</span> * will be called.<a name="line.312"></a> -<span class="sourceLineNo">313</span> * @param writeBufferSize The max size of internal buffer where data is stored.<a name="line.313"></a> -<span class="sourceLineNo">314</span> * @throws org.apache.hadoop.hbase.client.RetriesExhaustedWithDetailsException<a name="line.314"></a> -<span class="sourceLineNo">315</span> * if an I/O error occurs and there are too many retries.<a name="line.315"></a> -<span class="sourceLineNo">316</span> * @throws java.io.InterruptedIOException if the I/O task is interrupted.<a name="line.316"></a> -<span class="sourceLineNo">317</span> * @deprecated Going away when we drop public support for {@link HTable}.<a name="line.317"></a> -<span class="sourceLineNo">318</span> */<a name="line.318"></a> -<span class="sourceLineNo">319</span> @Deprecated<a name="line.319"></a> -<span class="sourceLineNo">320</span> public void setWriteBufferSize(long writeBufferSize) throws RetriesExhaustedWithDetailsException,<a name="line.320"></a> -<span class="sourceLineNo">321</span> InterruptedIOException {<a name="line.321"></a> -<span class="sourceLineNo">322</span> this.writeBufferSize = writeBufferSize;<a name="line.322"></a> -<span class="sourceLineNo">323</span> if (currentWriteBufferSize.get() > writeBufferSize) {<a name="line.323"></a> -<span class="sourceLineNo">324</span> flush();<a name="line.324"></a> -<span class="sourceLineNo">325</span> }<a name="line.325"></a> -<span class="sourceLineNo">326</span> }<a name="line.326"></a> -<span class="sourceLineNo">327</span><a name="line.327"></a> -<span class="sourceLineNo">328</span> /**<a name="line.328"></a> -<span class="sourceLineNo">329</span> * {@inheritDoc}<a name="line.329"></a> -<span class="sourceLineNo">330</span> */<a name="line.330"></a> -<span class="sourceLineNo">331</span> @Override<a name="line.331"></a> -<span class="sourceLineNo">332</span> public long getWriteBufferSize() {<a name="line.332"></a> -<span class="sourceLineNo">333</span> return this.writeBufferSize;<a name="line.333"></a> -<span class="sourceLineNo">334</span> }<a name="line.334"></a> -<span class="sourceLineNo">335</span><a name="line.335"></a> -<span class="sourceLineNo">336</span> @Override<a name="line.336"></a> -<span class="sourceLineNo">337</span> public void setRpcTimeout(int rpcTimeout) {<a name="line.337"></a> -<span class="sourceLineNo">338</span> this.rpcTimeout.set(rpcTimeout);<a name="line.338"></a> -<span class="sourceLineNo">339</span> }<a name="line.339"></a> -<span class="sourceLineNo">340</span><a name="line.340"></a> -<span class="sourceLineNo">341</span> @Override<a name="line.341"></a> -<span class="sourceLineNo">342</span> public void setOperationTimeout(int operationTimeout) {<a name="line.342"></a> -<span class="sourceLineNo">343</span> this.operationTimeout.set(operationTimeout);<a name="line.343"></a> -<span class="sourceLineNo">344</span> }<a name="line.344"></a> -<span class="sourceLineNo">345</span><a name="line.345"></a> -<span class="sourceLineNo">346</span> @VisibleForTesting<a name="line.346"></a> -<span class="sourceLineNo">347</span> long getCurrentWriteBufferSize() {<a name="line.347"></a> -<span class="sourceLineNo">348</span> return currentWriteBufferSize.get();<a name="line.348"></a> -<span class="sourceLineNo">349</span> }<a name="line.349"></a> -<span class="sourceLineNo">350</span><a name="line.350"></a> -<span class="sourceLineNo">351</span> @VisibleForTesting<a name="line.351"></a> -<span class="sourceLineNo">352</span> int size() {<a name="line.352"></a> -<span class="sourceLineNo">353</span> return undealtMutationCount.get();<a name="line.353"></a> -<span class="sourceLineNo">354</span> }<a name="line.354"></a> -<span class="sourceLineNo">355</span><a name="line.355"></a> -<span class="sourceLineNo">356</span> private class QueueRowAccess implements RowAccess<Row> {<a name="line.356"></a> -<span class="sourceLineNo">357</span> private int remainder = undealtMutationCount.getAndSet(0);<a name="line.357"></a> -<span class="sourceLineNo">358</span><a name="line.358"></a> -<span class="sourceLineNo">359</span> void reset() {<a name="line.359"></a> -<span class="sourceLineNo">360</span> restoreRemainder();<a name="line.360"></a> -<span class="sourceLineNo">361</span> remainder = undealtMutationCount.getAndSet(0);<a name="line.361"></a> -<span class="sourceLineNo">362</span> }<a name="line.362"></a> -<span class="sourceLineNo">363</span><a name="line.363"></a> -<span class="sourceLineNo">364</span> @Override<a name="line.364"></a> -<span class="sourceLineNo">365</span> public Iterator<Row> iterator() {<a name="line.365"></a> -<span class="sourceLineNo">366</span> return new Iterator<Row>() {<a name="line.366"></a> -<span class="sourceLineNo">367</span> private final Iterator<Mutation> iter = writeAsyncBuffer.iterator();<a name="line.367"></a> -<span class="sourceLineNo">368</span> private int countDown = remainder;<a name="line.368"></a> -<span class="sourceLineNo">369</span> private Mutation last = null;<a name="line.369"></a> +<span class="sourceLineNo">308</span><a name="line.308"></a> +<span class="sourceLineNo">309</span> /**<a name="line.309"></a> +<span class="sourceLineNo">310</span> * {@inheritDoc}<a name="line.310"></a> +<span class="sourceLineNo">311</span> */<a name="line.311"></a> +<span class="sourceLineNo">312</span> @Override<a name="line.312"></a> +<span class="sourceLineNo">313</span> public long getWriteBufferSize() {<a name="line.313"></a> +<span class="sourceLineNo">314</span> return this.writeBufferSize;<a name="line.314"></a> +<span class="sourceLineNo">315</span> }<a name="line.315"></a> +<span class="sourceLineNo">316</span><a name="line.316"></a> +<span class="sourceLineNo">317</span> @Override<a name="line.317"></a> +<span class="sourceLineNo">318</span> public void setRpcTimeout(int rpcTimeout) {<a name="line.318"></a> +<span class="sourceLineNo">319</span> this.rpcTimeout.set(rpcTimeout);<a name="line.319"></a> +<span class="sourceLineNo">320</span> }<a name="line.320"></a> +<span class="sourceLineNo">321</span><a name="line.321"></a> +<span class="sourceLineNo">322</span> @Override<a name="line.322"></a> +<span class="sourceLineNo">323</span> public void setOperationTimeout(int operationTimeout) {<a name="line.323"></a> +<span class="sourceLineNo">324</span> this.operationTimeout.set(operationTimeout);<a name="line.324"></a> +<span class="sourceLineNo">325</span> }<a name="line.325"></a> +<span class="sourceLineNo">326</span><a name="line.326"></a> +<span class="sourceLineNo">327</span> @VisibleForTesting<a name="line.327"></a> +<span class="sourceLineNo">328</span> long getCurrentWriteBufferSize() {<a name="line.328"></a> +<span class="sourceLineNo">329</span> return currentWriteBufferSize.get();<a name="line.329"></a> +<span class="sourceLineNo">330</span> }<a name="line.330"></a> +<span class="sourceLineNo">331</span><a name="line.331"></a> +<span class="sourceLineNo">332</span> @VisibleForTesting<a name="line.332"></a> +<span class="sourceLineNo">333</span> int size() {<a name="line.333"></a> +<span class="sourceLineNo">334</span> return undealtMutationCount.get();<a name="line.334"></a> +<span class="sourceLineNo">335</span> }<a name="line.335"></a> +<span class="sourceLineNo">336</span><a name="line.336"></a> +<span class="sourceLineNo">337</span> private class QueueRowAccess implements RowAccess<Row> {<a name="line.337"></a> +<span class="sourceLineNo">338</span> private int remainder = undealtMutationCount.getAndSet(0);<a name="line.338"></a> +<span class="sourceLineNo">339</span><a name="line.339"></a> +<span class="sourceLineNo">340</span> void reset() {<a name="line.340"></a> +<span class="sourceLineNo">341</span> restoreRemainder();<a name="line.341"></a> +<span class="sourceLineNo">342</span> remainder = undealtMutationCount.getAndSet(0);<a name="line.342"></a> +<span class="sourceLineNo">343</span> }<a name="line.343"></a> +<span class="sourceLineNo">344</span><a name="line.344"></a> +<span class="sourceLineNo">345</span> @Override<a name="line.345"></a> +<span class="sourceLineNo">346</span> public Iterator<Row> iterator() {<a name="line.346"></a> +<span class="sourceLineNo">347</span> return new Iterator<Row>() {<a name="line.347"></a> +<span class="sourceLineNo">348</span> private final Iterator<Mutation> iter = writeAsyncBuffer.iterator();<a name="line.348"></a> +<span class="sourceLineNo">349</span> private int countDown = remainder;<a name="line.349"></a> +<span class="sourceLineNo">350</span> private Mutation last = null;<a name="line.350"></a> +<span class="sourceLineNo">351</span> @Override<a name="line.351"></a> +<span class="sourceLineNo">352</span> public boolean hasNext() {<a name="line.352"></a> +<span class="sourceLineNo">353</span> if (countDown <= 0) {<a name="line.353"></a> +<span class="sourceLineNo">354</span> return false;<a name="line.354"></a> +<span class="sourceLineNo">355</span> }<a name="line.355"></a> +<span class="sourceLineNo">356</span> return iter.hasNext();<a name="line.356"></a> +<span class="sourceLineNo">357</span> }<a name="line.357"></a> +<span class="sourceLineNo">358</span> @Override<a name="line.358"></a> +<span class="sourceLineNo">359</span> public Row next() {<a name="line.359"></a> +<span class="sourceLineNo">360</span> if (!hasNext()) {<a name="line.360"></a> +<span class="sourceLineNo">361</span> throw new NoSuchElementException();<a name="line.361"></a> +<span class="sourceLineNo">362</span> }<a name="line.362"></a> +<span class="sourceLineNo">363</span> last = iter.next();<a name="line.363"></a> +<span class="sourceLineNo">364</span> if (last == null) {<a name="line.364"></a> +<span class="sourceLineNo">365</span> throw new NoSuchElementException();<a name="line.365"></a> +<span class="sourceLineNo">366</span> }<a name="line.366"></a> +<span class="sourceLineNo">367</span> --countDown;<a name="line.367"></a> +<span class="sourceLineNo">368</span> return last;<a name="line.368"></a> +<span class="sourceLineNo">369</span> }<a name="line.369"></a> <span class="sourceLineNo">370</span> @Override<a name="line.370"></a> -<span class="sourceLineNo">371</span> public boolean hasNext() {<a name="line.371"></a> -<span class="sourceLineNo">372</span> if (countDown <= 0) {<a name="line.372"></a> -<span class="sourceLineNo">373</span> return false;<a name="line.373"></a> +<span class="sourceLineNo">371</span> public void remove() {<a name="line.371"></a> +<span class="sourceLineNo">372</span> if (last == null) {<a name="line.372"></a> +<span class="sourceLineNo">373</span> throw new IllegalStateException();<a name="line.373"></a> <span class="sourceLineNo">374</span> }<a name="line.374"></a> -<span class="sourceLineNo">375</span> return iter.hasNext();<a name="line.375"></a> -<span class="sourceLineNo">376</span> }<a name="line.376"></a> -<span class="sourceLineNo">377</span> @Override<a name="line.377"></a> -<span class="sourceLineNo">378</span> public Row next() {<a name="line.378"></a> -<span class="sourceLineNo">379</span> if (!hasNext()) {<a name="line.379"></a> -<span class="sourceLineNo">380</span> throw new NoSuchElementException();<a name="line.380"></a> -<span class="sourceLineNo">381</span> }<a name="line.381"></a> -<span class="sourceLineNo">382</span> last = iter.next();<a name="line.382"></a> -<span class="sourceLineNo">383</span> if (last == null) {<a name="line.383"></a> -<span class="sourceLineNo">384</span> throw new NoSuchElementException();<a name="line.384"></a> -<span class="sourceLineNo">385</span> }<a name="line.385"></a> -<span class="sourceLineNo">386</span> --countDown;<a name="line.386"></a> -<span class="sourceLineNo">387</span> return last;<a name="line.387"></a> -<span class="sourceLineNo">388</span> }<a name="line.388"></a> -<span class="sourceLineNo">389</span> @Override<a name="line.389"></a> -<span class="sourceLineNo">390</span> public void remove() {<a name="line.390"></a> -<span class="sourceLineNo">391</span> if (last == null) {<a name="line.391"></a> -<span class="sourceLineNo">392</span> throw new IllegalStateException();<a name="line.392"></a> -<span class="sourceLineNo">393</span> }<a name="line.393"></a> -<span class="sourceLineNo">394</span> iter.remove();<a name="line.394"></a> -<span class="sourceLineNo">395</span> currentWriteBufferSize.addAndGet(-last.heapSize());<a name="line.395"></a> -<span class="sourceLineNo">396</span> --remainder;<a name="line.396"></a> -<span class="sourceLineNo">397</span> }<a name="line.397"></a> -<span class="sourceLineNo">398</span> };<a name="line.398"></a> -<span class="sourceLineNo">399</span> }<a name="line.399"></a> -<span class="sourceLineNo">400</span><a name="line.400"></a> -<span class="sourceLineNo">401</span> @Override<a name="line.401"></a> -<span class="sourceLineNo">402</span> public int size() {<a name="line.402"></a> -<span class="sourceLineNo">403</span> return remainder;<a name="line.403"></a> -<span class="sourceLineNo">404</span> }<a name="line.404"></a> -<span class="sourceLineNo">405</span><a name="line.405"></a> -<span class="sourceLineNo">406</span> void restoreRemainder() {<a name="line.406"></a> -<span class="sourceLineNo">407</span> if (remainder > 0) {<a name="line.407"></a> -<span class="sourceLineNo">408</span> undealtMutationCount.addAndGet(remainder);<a name="line.408"></a> -<span class="sourceLineNo">409</span> remainder = 0;<a name="line.409"></a> -<span class="sourceLineNo">410</span> }<a name="line.410"></a> -<span class="sourceLineNo">411</span> }<a name="line.411"></a> -<span class="sourceLineNo">412</span><a name="line.412"></a> -<span class="sourceLineNo">413</span> @Override<a name="line.413"></a> -<span class="sourceLineNo">414</span> public boolean isEmpty() {<a name="line.414"></a> -<span class="sourceLineNo">415</span> return remainder <= 0;<a name="line.415"></a> -<span class="sourceLineNo">416</span> }<a name="line.416"></a> -<span class="sourceLineNo">417</span> }<a name="line.417"></a> -<span class="sourceLineNo">418</span>}<a name="line.418"></a> +<span class="sourceLineNo">375</span> iter.remove();<a name="line.375"></a> +<span class="sourceLineNo">376</span> currentWriteBufferSize.addAndGet(-last.heapSize());<a name="line.376"></a> +<span class="sourceLineNo">377</span> --remainder;<a name="line.377"></a> +<span class="sourceLineNo">378</span> }<a name="line.378"></a> +<span class="sourceLineNo">379</span> };<a name="line.379"></a> +<span class="sourceLineNo">380</span> }<a name="line.380"></a> +<span class="sourceLineNo">381</span><a name="line.381"></a> +<span class="sourceLineNo">382</span> @Override<a name="line.382"></a> +<span class="sourceLineNo">383</span> public int size() {<a name="line.383"></a> +<span class="sourceLineNo">384</span> return remainder;<a name="line.384"></a> +<span class="sourceLineNo">385</span> }<a name="line.385"></a> +<span class="sourceLineNo">386</span><a name="line.386"></a> +<span class="sourceLineNo">387</span> void restoreRemainder() {<a name="line.387"></a> +<span class="sourceLineNo">388</span> if (remainder > 0) {<a name="line.388"></a> +<span class="sourceLineNo">389</span> undealtMutationCount.addAndGet(remainder);<a name="line.389"></a> +<span class="sourceLineNo">390</span> remainder = 0;<a name="line.390"></a> +<span class="sourceLineNo">391</span> }<a name="line.391"></a> +<span class="sourceLineNo">392</span> }<a name="line.392"></a> +<span class="sourceLineNo">393</span><a name="line.393"></a> +<span class="sourceLineNo">394</span> @Override<a name="line.394"></a> +<span class="sourceLineNo">395</span> public boolean isEmpty() {<a name="line.395"></a> +<span class="sourceLineNo">396</span> return remainder <= 0;<a name="line.396"></a> +<span class="sourceLineNo">397</span> }<a name="line.397"></a> +<span class="sourceLineNo">398</span> }<a name="line.398"></a> +<span class="sourceLineNo">399</span>}<a name="line.399"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html index 216bf8d..7c8ee35 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html @@ -313,117 +313,98 @@ <span class="sourceLineNo">305</span> }<a name="line.305"></a> <span class="sourceLineNo">306</span> };<a name="line.306"></a> <span class="sourceLineNo">307</span> }<a name="line.307"></a> -<span class="sourceLineNo">308</span> /**<a name="line.308"></a> -<span class="sourceLineNo">309</span> * This is used for legacy purposes in {@link HTable#setWriteBufferSize(long)} only. This ought<a name="line.309"></a> -<span class="sourceLineNo">310</span> * not be called for production uses.<a name="line.310"></a> -<span class="sourceLineNo">311</span> * If the new buffer size is smaller than the stored data, the {@link BufferedMutatorImpl#flush()}<a name="line.311"></a> -<span class="sourceLineNo">312</span> * will be called.<a name="line.312"></a> -<span class="sourceLineNo">313</span> * @param writeBufferSize The max size of internal buffer where data is stored.<a name="line.313"></a> -<span class="sourceLineNo">314</span> * @throws org.apache.hadoop.hbase.client.RetriesExhaustedWithDetailsException<a name="line.314"></a> -<span class="sourceLineNo">315</span> * if an I/O error occurs and there are too many retries.<a name="line.315"></a> -<span class="sourceLineNo">316</span> * @throws java.io.InterruptedIOException if the I/O task is interrupted.<a name="line.316"></a> -<span class="sourceLineNo">317</span> * @deprecated Going away when we drop public support for {@link HTable}.<a name="line.317"></a> -<span class="sourceLineNo">318</span> */<a name="line.318"></a> -<span class="sourceLineNo">319</span> @Deprecated<a name="line.319"></a> -<span class="sourceLineNo">320</span> public void setWriteBufferSize(long writeBufferSize) throws RetriesExhaustedWithDetailsException,<a name="line.320"></a> -<span class="sourceLineNo">321</span> InterruptedIOException {<a name="line.321"></a> -<span class="sourceLineNo">322</span> this.writeBufferSize = writeBufferSize;<a name="line.322"></a> -<span class="sourceLineNo">323</span> if (currentWriteBufferSize.get() > writeBufferSize) {<a name="line.323"></a> -<span class="sourceLineNo">324</span> flush();<a name="line.324"></a> -<span class="sourceLineNo">325</span> }<a name="line.325"></a> -<span class="sourceLineNo">326</span> }<a name="line.326"></a> -<span class="sourceLineNo">327</span><a name="line.327"></a> -<span class="sourceLineNo">328</span> /**<a name="line.328"></a> -<span class="sourceLineNo">329</span> * {@inheritDoc}<a name="line.329"></a> -<span class="sourceLineNo">330</span> */<a name="line.330"></a> -<span class="sourceLineNo">331</span> @Override<a name="line.331"></a> -<span class="sourceLineNo">332</span> public long getWriteBufferSize() {<a name="line.332"></a> -<span class="sourceLineNo">333</span> return this.writeBufferSize;<a name="line.333"></a> -<span class="sourceLineNo">334</span> }<a name="line.334"></a> -<span class="sourceLineNo">335</span><a name="line.335"></a> -<span class="sourceLineNo">336</span> @Override<a name="line.336"></a> -<span class="sourceLineNo">337</span> public void setRpcTimeout(int rpcTimeout) {<a name="line.337"></a> -<span class="sourceLineNo">338</span> this.rpcTimeout.set(rpcTimeout);<a name="line.338"></a> -<span class="sourceLineNo">339</span> }<a name="line.339"></a> -<span class="sourceLineNo">340</span><a name="line.340"></a> -<span class="sourceLineNo">341</span> @Override<a name="line.341"></a> -<span class="sourceLineNo">342</span> public void setOperationTimeout(int operationTimeout) {<a name="line.342"></a> -<span class="sourceLineNo">343</span> this.operationTimeout.set(operationTimeout);<a name="line.343"></a> -<span class="sourceLineNo">344</span> }<a name="line.344"></a> -<span class="sourceLineNo">345</span><a name="line.345"></a> -<span class="sourceLineNo">346</span> @VisibleForTesting<a name="line.346"></a> -<span class="sourceLineNo">347</span> long getCurrentWriteBufferSize() {<a name="line.347"></a> -<span class="sourceLineNo">348</span> return currentWriteBufferSize.get();<a name="line.348"></a> -<span class="sourceLineNo">349</span> }<a name="line.349"></a> -<span class="sourceLineNo">350</span><a name="line.350"></a> -<span class="sourceLineNo">351</span> @VisibleForTesting<a name="line.351"></a> -<span class="sourceLineNo">352</span> int size() {<a name="line.352"></a> -<span class="sourceLineNo">353</span> return undealtMutationCount.get();<a name="line.353"></a> -<span class="sourceLineNo">354</span> }<a name="line.354"></a> -<span class="sourceLineNo">355</span><a name="line.355"></a> -<span class="sourceLineNo">356</span> private class QueueRowAccess implements RowAccess<Row> {<a name="line.356"></a> -<span class="sourceLineNo">357</span> private int remainder = undealtMutationCount.getAndSet(0);<a name="line.357"></a> -<span class="sourceLineNo">358</span><a name="line.358"></a> -<span class="sourceLineNo">359</span> void reset() {<a name="line.359"></a> -<span class="sourceLineNo">360</span> restoreRemainder();<a name="line.360"></a> -<span class="sourceLineNo">361</span> remainder = undealtMutationCount.getAndSet(0);<a name="line.361"></a> -<span class="sourceLineNo">362</span> }<a name="line.362"></a> -<span class="sourceLineNo">363</span><a name="line.363"></a> -<span class="sourceLineNo">364</span> @Override<a name="line.364"></a> -<span class="sourceLineNo">365</span> public Iterator<Row> iterator() {<a name="line.365"></a> -<span class="sourceLineNo">366</span> return new Iterator<Row>() {<a name="line.366"></a> -<span class="sourceLineNo">367</span> private final Iterator<Mutation> iter = writeAsyncBuffer.iterator();<a name="line.367"></a> -<span class="sourceLineNo">368</span> private int countDown = remainder;<a name="line.368"></a> -<span class="sourceLineNo">369</span> private Mutation last = null;<a name="line.369"></a> +<span class="sourceLineNo">308</span><a name="line.308"></a> +<span class="sourceLineNo">309</span> /**<a name="line.309"></a> +<span class="sourceLineNo">310</span> * {@inheritDoc}<a name="line.310"></a> +<span class="sourceLineNo">311</span> */<a name="line.311"></a> +<span class="sourceLineNo">312</span> @Override<a name="line.312"></a> +<span class="sourceLineNo">313</span> public long getWriteBufferSize() {<a name="line.313"></a> +<span class="sourceLineNo">314</span> return this.writeBufferSize;<a name="line.314"></a> +<span class="sourceLineNo">315</span> }<a name="line.315"></a> +<span class="sourceLineNo">316</span><a name="line.316"></a> +<span class="sourceLineNo">317</span> @Override<a name="line.317"></a> +<span class="sourceLineNo">318</span> public void setRpcTimeout(int rpcTimeout) {<a name="line.318"></a> +<span class="sourceLineNo">319</span> this.rpcTimeout.set(rpcTimeout);<a name="line.319"></a> +<span class="sourceLineNo">320</span> }<a name="line.320"></a> +<span class="sourceLineNo">321</span><a name="line.321"></a> +<span class="sourceLineNo">322</span> @Override<a name="line.322"></a> +<span class="sourceLineNo">323</span> public void setOperationTimeout(int operationTimeout) {<a name="line.323"></a> +<span class="sourceLineNo">324</span> this.operationTimeout.set(operationTimeout);<a name="line.324"></a> +<span class="sourceLineNo">325</span> }<a name="line.325"></a> +<span class="sourceLineNo">326</span><a name="line.326"></a> +<span class="sourceLineNo">327</span> @VisibleForTesting<a name="line.327"></a> +<span class="sourceLineNo">328</span> long getCurrentWriteBufferSize() {<a name="line.328"></a> +<span class="sourceLineNo">329</span> return currentWriteBufferSize.get();<a name="line.329"></a> +<span class="sourceLineNo">330</span> }<a name="line.330"></a> +<span class="sourceLineNo">331</span><a name="line.331"></a> +<span class="sourceLineNo">332</span> @VisibleForTesting<a name="line.332"></a> +<span class="sourceLineNo">333</span> int size() {<a name="line.333"></a> +<span class="sourceLineNo">334</span> return undealtMutationCount.get();<a name="line.334"></a> +<span class="sourceLineNo">335</span> }<a name="line.335"></a> +<span class="sourceLineNo">336</span><a name="line.336"></a> +<span class="sourceLineNo">337</span> private class QueueRowAccess implements RowAccess<Row> {<a name="line.337"></a> +<span class="sourceLineNo">338</span> private int remainder = undealtMutationCount.getAndSet(0);<a name="line.338"></a> +<span class="sourceLineNo">339</span><a name="line.339"></a> +<span class="sourceLineNo">340</span> void reset() {<a name="line.340"></a> +<span class="sourceLineNo">341</span> restoreRemainder();<a name="line.341"></a> +<span class="sourceLineNo">342</span> remainder = undealtMutationCount.getAndSet(0);<a name="line.342"></a> +<span class="sourceLineNo">343</span> }<a name="line.343"></a> +<span class="sourceLineNo">344</span><a name="line.344"></a> +<span class="sourceLineNo">345</span> @Override<a name="line.345"></a> +<span class="sourceLineNo">346</span> public Iterator<Row> iterator() {<a name="line.346"></a> +<span class="sourceLineNo">347</span> return new Iterator<Row>() {<a name="line.347"></a> +<span class="sourceLineNo">348</span> private final Iterator<Mutation> iter = writeAsyncBuffer.iterator();<a name="line.348"></a> +<span class="sourceLineNo">349</span> private int countDown = remainder;<a name="line.349"></a> +<span class="sourceLineNo">350</span> private Mutation last = null;<a name="line.350"></a> +<span class="sourceLineNo">351</span> @Override<a name="line.351"></a> +<span class="sourceLineNo">352</span> public boolean hasNext() {<a name="line.352"></a> +<span class="sourceLineNo">353</span> if (countDown <= 0) {<a name="line.353"></a> +<span class="sourceLineNo">354</span> return false;<a name="line.354"></a> +<span class="sourceLineNo">355</span> }<a name="line.355"></a> +<span class="sourceLineNo">356</span> return iter.hasNext();<a name="line.356"></a> +<span class="sourceLineNo">357</span> }<a name="line.357"></a> +<span class="sourceLineNo">358</span> @Override<a name="line.358"></a> +<span class="sourceLineNo">359</span> public Row next() {<a name="line.359"></a> +<span class="sourceLineNo">360</span> if (!hasNext()) {<a name="line.360"></a> +<span class="sourceLineNo">361</span> throw new NoSuchElementException();<a name="line.361"></a> +<span class="sourceLineNo">362</span> }<a name="line.362"></a> +<span class="sourceLineNo">363</span> last = iter.next();<a name="line.363"></a> +<span class="sourceLineNo">364</span> if (last == null) {<a name="line.364"></a> +<span class="sourceLineNo">365</span> throw new NoSuchElementException();<a name="line.365"></a> +<span class="sourceLineNo">366</span> }<a name="line.366"></a> +<span class="sourceLineNo">367</span> --countDown;<a name="line.367"></a> +<span class="sourceLineNo">368</span> return last;<a name="line.368"></a> +<span class="sourceLineNo">369</span> }<a name="line.369"></a> <span class="sourceLineNo">370</span> @Override<a name="line.370"></a> -<span class="sourceLineNo">371</span> public boolean hasNext() {<a name="line.371"></a> -<span class="sourceLineNo">372</span> if (countDown <= 0) {<a name="line.372"></a> -<span class="sourceLineNo">373</span> return false;<a name="line.373"></a> +<span class="sourceLineNo">371</span> public void remove() {<a name="line.371"></a> +<span class="sourceLineNo">372</span> if (last == null) {<a name="line.372"></a> +<span class="sourceLineNo">373</span> throw new IllegalStateException();<a name="line.373"></a> <span class="sourceLineNo">374</span> }<a name="line.374"></a> -<span class="sourceLineNo">375</span> return iter.hasNext();<a name="line.375"></a> -<span class="sourceLineNo">376</span> }<a name="line.376"></a> -<span class="sourceLineNo">377</span> @Override<a name="line.377"></a> -<span class="sourceLineNo">378</span> public Row next() {<a name="line.378"></a> -<span class="sourceLineNo">379</span> if (!hasNext()) {<a name="line.379"></a> -<span class="sourceLineNo">380</span> throw new NoSuchElementException();<a name="line.380"></a> -<span class="sourceLineNo">381</span> }<a name="line.381"></a> -<span class="sourceLineNo">382</span> last = iter.next();<a name="line.382"></a> -<span class="sourceLineNo">383</span> if (last == null) {<a name="line.383"></a> -<span class="sourceLineNo">384</span> throw new NoSuchElementException();<a name="line.384"></a> -<span class="sourceLineNo">385</span> }<a name="line.385"></a> -<span class="sourceLineNo">386</span> --countDown;<a name="line.386"></a> -<span class="sourceLineNo">387</span> return last;<a name="line.387"></a> -<span class="sourceLineNo">388</span> }<a name="line.388"></a> -<span class="sourceLineNo">389</span> @Override<a name="line.389"></a> -<span class="sourceLineNo">390</span> public void remove() {<a name="line.390"></a> -<span class="sourceLineNo">391</span> if (last == null) {<a name="line.391"></a> -<span class="sourceLineNo">392</span> throw new IllegalStateException();<a name="line.392"></a> -<span class="sourceLineNo">393</span> }<a name="line.393"></a> -<span class="sourceLineNo">394</span> iter.remove();<a name="line.394"></a> -<span class="sourceLineNo">395</span> currentWriteBufferSize.addAndGet(-last.heapSize());<a name="line.395"></a> -<span class="sourceLineNo">396</span> --remainder;<a name="line.396"></a> -<span class="sourceLineNo">397</span> }<a name="line.397"></a> -<span class="sourceLineNo">398</span> };<a name="line.398"></a> -<span class="sourceLineNo">399</span> }<a name="line.399"></a> -<span class="sourceLineNo">400</span><a name="line.400"></a> -<span class="sourceLineNo">401</span> @Override<a name="line.401"></a> -<span class="sourceLineNo">402</span> public int size() {<a name="line.402"></a> -<span class="sourceLineNo">403</span> return remainder;<a name="line.403"></a> -<span class="sourceLineNo">404</span> }<a name="line.404"></a> -<span class="sourceLineNo">405</span><a name="line.405"></a> -<span class="sourceLineNo">406</span> void restoreRemainder() {<a name="line.406"></a> -<span class="sourceLineNo">407</span> if (remainder > 0) {<a name="line.407"></a> -<span class="sourceLineNo">408</span> undealtMutationCount.addAndGet(remainder);<a name="line.408"></a> -<span class="sourceLineNo">409</span> remainder = 0;<a name="line.409"></a> -<span class="sourceLineNo">410</span> }<a name="line.410"></a> -<span class="sourceLineNo">411</span> }<a name="line.411"></a> -<span class="sourceLineNo">412</span><a name="line.412"></a> -<span class="sourceLineNo">413</span> @Override<a name="line.413"></a> -<span class="sourceLineNo">414</span> public boolean isEmpty() {<a name="line.414"></a> -<span class="sourceLineNo">415</span> return remainder <= 0;<a name="line.415"></a> -<span class="sourceLineNo">416</span> }<a name="line.416"></a> -<span class="sourceLineNo">417</span> }<a name="line.417"></a> -<span class="sourceLineNo">418</span>}<a name="line.418"></a> +<span class="sourceLineNo">375</span> iter.remove();<a name="line.375"></a> +<span class="sourceLineNo">376</span> currentWriteBufferSize.addAndGet(-last.heapSize());<a name="line.376"></a> +<span class="sourceLineNo">377</span> --remainder;<a name="line.377"></a> +<span class="sourceLineNo">378</span> }<a name="line.378"></a> +<span class="sourceLineNo">379</span> };<a name="line.379"></a> +<span class="sourceLineNo">380</span> }<a name="line.380"></a> +<span class="sourceLineNo">381</span><a name="line.381"></a> +<span class="sourceLineNo">382</span> @Override<a name="line.382"></a> +<span class="sourceLineNo">383</span> public int size() {<a name="line.383"></a> +<span class="sourceLineNo">384</span> return remainder;<a name="line.384"></a> +<span class="sourceLineNo">385</span> }<a name="line.385"></a> +<span class="sourceLineNo">386</span><a name="line.386"></a> +<span class="sourceLineNo">387</span> void restoreRemainder() {<a name="line.387"></a> +<span class="sourceLineNo">388</span> if (remainder > 0) {<a name="line.388"></a> +<span class="sourceLineNo">389</span> undealtMutationCount.addAndGet(remainder);<a name="line.389"></a> +<span class="sourceLineNo">390</span> remainder = 0;<a name="line.390"></a> +<span class="sourceLineNo">391</span> }<a name="line.391"></a> +<span class="sourceLineNo">392</span> }<a name="line.392"></a> +<span class="sourceLineNo">393</span><a name="line.393"></a> +<span class="sourceLineNo">394</span> @Override<a name="line.394"></a> +<span class="sourceLineNo">395</span> public boolean isEmpty() {<a name="line.395"></a> +<span class="sourceLineNo">396</span> return remainder <= 0;<a name="line.396"></a> +<span class="sourceLineNo">397</span> }<a name="line.397"></a> +<span class="sourceLineNo">398</span> }<a name="line.398"></a> +<span class="sourceLineNo">399</span>}<a name="line.399"></a>
