http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f1b07859/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html index 852bd23..46e0c1a 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -290,39 +290,47 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#isFinished--">isFinished</a></span>()</code> </td> </tr> <tr id="i8" class="altColor"> +<td class="colFirst"><code>protected void</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#postFinish--">postFinish</a></span>()</code> </td> +</tr> +<tr id="i9" class="rowColor"> +<td class="colFirst"><code>protected void</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#postShipEdits-org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch-">postShipEdits</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> entryBatch)</code> </td> +</tr> +<tr id="i10" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#run--">run</a></span>()</code> </td> </tr> -<tr id="i9" class="rowColor"> +<tr id="i11" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#setWALReader-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader-">setWALReader</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader</a> entryReader)</code> </td> </tr> -<tr id="i10" class="altColor"> +<tr id="i12" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#setWorkerState-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceShipper.WorkerState-">setWorkerState</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html" title="enum in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper.WorkerState</a> state)</code> </td> </tr> -<tr id="i11" class="rowColor"> +<tr id="i13" class="rowColor"> <td class="colFirst"><code>protected void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#shipEdits-org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch-">shipEdits</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> entryBatch)</code> <div class="block">Do the shipping logic</div> </td> </tr> -<tr id="i12" class="altColor"> +<tr id="i14" class="altColor"> <td class="colFirst"><code>boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#sleepForRetries-java.lang.String-int-">sleepForRetries</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> msg, int sleepMultiplier)</code> <div class="block">Do the sleeping logic</div> </td> </tr> -<tr id="i13" class="rowColor"> +<tr id="i15" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#startup-java.lang.Thread.UncaughtExceptionHandler-">startup</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.UncaughtExceptionHandler.html?is-external=true"; title="class or interface in java.lang">Thread.UncaughtExceptionHandler</a> handler)</code> </td> </tr> -<tr id="i14" class="altColor"> +<tr id="i16" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#stopWorker--">stopWorker</a></span>()</code> </td> </tr> -<tr id="i15" class="rowColor"> +<tr id="i17" class="rowColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#updateLogPosition-long-java.util.Map-">updateLogPosition</a></span>(long lastReadPosition, <a href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="https://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="https://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</a>> lastSeqIds)</code> </td> @@ -489,7 +497,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>run</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.86">run</a>()</pre> +<pre>public final void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.86">run</a>()</pre> <dl> <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true#run--"; title="class or interface in java.lang">run</a></code> in interface <code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true"; title="class or interface in java.lang">Runnable</a></code></dd> @@ -498,13 +506,31 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html </dl> </li> </ul> +<a name="postShipEdits-org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>postShipEdits</h4> +<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.116">postShipEdits</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> entryBatch)</pre> +</li> +</ul> +<a name="postFinish--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>postFinish</h4> +<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.120">postFinish</a>()</pre> +</li> +</ul> <a name="shipEdits-org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch-"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>shipEdits</h4> -<pre>protected final void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.123">shipEdits</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> entryBatch)</pre> +<pre>protected final void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.126">shipEdits</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> entryBatch)</pre> <div class="block">Do the shipping logic</div> </li> </ul> @@ -514,7 +540,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>cleanUpHFileRefs</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.200">cleanUpHFileRefs</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a> edit) +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.203">cleanUpHFileRefs</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a> edit) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -528,7 +554,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>updateLogPosition</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.224">updateLogPosition</a>(long lastReadPosition, +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.227">updateLogPosition</a>(long lastReadPosition, <a href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="https://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="https://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</a>> lastSeqIds)</pre> </li> </ul> @@ -538,7 +564,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>startup</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.230">startup</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.UncaughtExceptionHandler.html?is-external=true"; title="class or interface in java.lang">Thread.UncaughtExceptionHandler</a> handler)</pre> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.233">startup</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.UncaughtExceptionHandler.html?is-external=true"; title="class or interface in java.lang">Thread.UncaughtExceptionHandler</a> handler)</pre> </li> </ul> <a name="getLogQueue--"> @@ -547,7 +573,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>getLogQueue</h4> -<pre>public <a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/PriorityBlockingQueue.html?is-external=true"; title="class or interface in java.util.concurrent">PriorityBlockingQueue</a><org.apache.hadoop.fs.Path> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.236">getLogQueue</a>()</pre> +<pre>public <a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/PriorityBlockingQueue.html?is-external=true"; title="class or interface in java.util.concurrent">PriorityBlockingQueue</a><org.apache.hadoop.fs.Path> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.239">getLogQueue</a>()</pre> </li> </ul> <a name="getCurrentPath--"> @@ -556,7 +582,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>getCurrentPath</h4> -<pre>public org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.240">getCurrentPath</a>()</pre> +<pre>public org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.243">getCurrentPath</a>()</pre> </li> </ul> <a name="getCurrentPosition--"> @@ -565,7 +591,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>getCurrentPosition</h4> -<pre>public long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.244">getCurrentPosition</a>()</pre> +<pre>public long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.247">getCurrentPosition</a>()</pre> </li> </ul> <a name="setWALReader-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader-"> @@ -574,7 +600,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>setWALReader</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.248">setWALReader</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader</a> entryReader)</pre> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.251">setWALReader</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader</a> entryReader)</pre> </li> </ul> <a name="getStartPosition--"> @@ -583,7 +609,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>getStartPosition</h4> -<pre>public long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.252">getStartPosition</a>()</pre> +<pre>public long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.255">getStartPosition</a>()</pre> </li> </ul> <a name="isActive--"> @@ -592,7 +618,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>isActive</h4> -<pre>protected final boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.256">isActive</a>()</pre> +<pre>protected final boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.259">isActive</a>()</pre> </li> </ul> <a name="setWorkerState-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceShipper.WorkerState-"> @@ -601,7 +627,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>setWorkerState</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.260">setWorkerState</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html" title="enum in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper.WorkerState</a> state)</pre> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.263">setWorkerState</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html" title="enum in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper.WorkerState</a> state)</pre> </li> </ul> <a name="getWorkerState--"> @@ -610,7 +636,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>getWorkerState</h4> -<pre>public <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html" title="enum in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper.WorkerState</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.264">getWorkerState</a>()</pre> +<pre>public <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html" title="enum in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper.WorkerState</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.267">getWorkerState</a>()</pre> </li> </ul> <a name="stopWorker--"> @@ -619,7 +645,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>stopWorker</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.268">stopWorker</a>()</pre> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.271">stopWorker</a>()</pre> </li> </ul> <a name="isFinished--"> @@ -628,7 +654,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>isFinished</h4> -<pre>public boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.272">isFinished</a>()</pre> +<pre>public boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.275">isFinished</a>()</pre> </li> </ul> <a name="sleepForRetries-java.lang.String-int-"> @@ -637,7 +663,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockListLast"> <li class="blockList"> <h4>sleepForRetries</h4> -<pre>public boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.282">sleepForRetries</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> msg, +<pre>public boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.285">sleepForRetries</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> msg, int sleepMultiplier)</pre> <div class="block">Do the sleeping logic</div> <dl>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f1b07859/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html index 3e926b9..dfd64bd 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -118,13 +118,13 @@ var activeTableTab = "activeTableTab"; </dl> <dl> <dt>Direct Known Subclasses:</dt> -<dd><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/RecoveredReplicationSourceWALReader.html" title="class in org.apache.hadoop.hbase.replication.regionserver">RecoveredReplicationSourceWALReader</a></dd> +<dd><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/SerialReplicationSourceWALReader.html" title="class in org.apache.hadoop.hbase.replication.regionserver">SerialReplicationSourceWALReader</a></dd> </dl> <hr> <br> <pre>@InterfaceAudience.Private @InterfaceStability.Evolving -public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.54">ReplicationSourceWALReader</a> +class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.53">ReplicationSourceWALReader</a> extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true"; title="class or interface in java.lang">Thread</a></pre> <div class="block">Reads and filters WAL entries, groups the filtered entries into batches, and puts the batches onto a queue</div> @@ -182,41 +182,33 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#filter">filter</a></span></code> </td> </tr> <tr class="rowColor"> -<td class="colFirst"><code>private <a href="../../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a></code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#firstCellInEntryBeforeFiltering">firstCellInEntryBeforeFiltering</a></span></code> </td> -</tr> -<tr class="altColor"> <td class="colFirst"><code>private org.apache.hadoop.fs.FileSystem</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#fs">fs</a></span></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#isReaderRunning">isReaderRunning</a></span></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private static org.slf4j.Logger</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#LOG">LOG</a></span></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private <a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/PriorityBlockingQueue.html?is-external=true"; title="class or interface in java.util.concurrent">PriorityBlockingQueue</a><org.apache.hadoop.fs.Path></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#logQueue">logQueue</a></span></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#maxRetriesMultiplier">maxRetriesMultiplier</a></span></code> </td> </tr> -<tr class="rowColor"> -<td class="colFirst"><code>protected int</code></td> +<tr class="altColor"> +<td class="colFirst"><code>private int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#replicationBatchCountCapacity">replicationBatchCountCapacity</a></span></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#replicationBatchSizeCapacity">replicationBatchSizeCapacity</a></span></code> </td> </tr> -<tr class="rowColor"> -<td class="colFirst"><code>private <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/SerialReplicationChecker.html" title="class in org.apache.hadoop.hbase.replication.regionserver">SerialReplicationChecker</a></code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#serialReplicationChecker">serialReplicationChecker</a></span></code> </td> -</tr> <tr class="altColor"> <td class="colFirst"><code>private long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#sleepForRetries">sleepForRetries</a></span></code> </td> @@ -284,70 +276,74 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#acquireBufferQuota-long-">acquireBufferQuota</a></span>(long size)</code> </td> </tr> <tr id="i1" class="rowColor"> +<td class="colFirst"><code>protected boolean</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#addEntryToBatch-org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch-org.apache.hadoop.hbase.wal.WAL.Entry-">addEntryToBatch</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> batch, + <a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</code> </td> +</tr> +<tr id="i2" class="altColor"> <td class="colFirst"><code>private int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#calculateTotalSizeOfStoreFiles-org.apache.hadoop.hbase.wal.WALEdit-">calculateTotalSizeOfStoreFiles</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a> edit)</code> <div class="block">Calculate the total size of all the store files</div> </td> </tr> -<tr id="i2" class="altColor"> +<tr id="i3" class="rowColor"> <td class="colFirst"><code>private boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#checkQuota--">checkQuota</a></span>()</code> </td> </tr> -<tr id="i3" class="rowColor"> +<tr id="i4" class="altColor"> <td class="colFirst"><code>private <a href="../../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>,<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#countDistinctRowKeysAndHFiles-org.apache.hadoop.hbase.wal.WALEdit-">countDistinctRowKeysAndHFiles</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a> edit)</code> <div class="block">Count the number of different row keys in the given edit because of mini-batching.</div> </td> </tr> -<tr id="i4" class="altColor"> -<td class="colFirst"><code>private <a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a></code></td> +<tr id="i5" class="rowColor"> +<td class="colFirst"><code>protected <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#createBatch-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-">createBatch</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream)</code> </td> +</tr> +<tr id="i6" class="altColor"> +<td class="colFirst"><code>protected <a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#filterEntry-org.apache.hadoop.hbase.wal.WAL.Entry-">filterEntry</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</code> </td> </tr> -<tr id="i5" class="rowColor"> +<tr id="i7" class="rowColor"> <td class="colFirst"><code>org.apache.hadoop.fs.Path</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#getCurrentPath--">getCurrentPath</a></span>()</code> </td> </tr> -<tr id="i6" class="altColor"> +<tr id="i8" class="altColor"> <td class="colFirst"><code>private long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#getEntrySize-org.apache.hadoop.hbase.wal.WAL.Entry-">getEntrySize</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</code> </td> </tr> -<tr id="i7" class="rowColor"> +<tr id="i9" class="rowColor"> <td class="colFirst"><code>protected void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#handleEmptyWALEntryBatch-org.apache.hadoop.fs.Path-">handleEmptyWALEntryBatch</a></span>(org.apache.hadoop.fs.Path currentPath)</code> </td> </tr> -<tr id="i8" class="altColor"> +<tr id="i10" class="altColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#handleEofException-java.io.IOException-">handleEofException</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a> e)</code> </td> </tr> -<tr id="i9" class="rowColor"> +<tr id="i11" class="rowColor"> <td class="colFirst"><code>boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#isReaderRunning--">isReaderRunning</a></span>()</code> </td> </tr> -<tr id="i10" class="altColor"> -<td class="colFirst"><code>private <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a></code></td> +<tr id="i12" class="altColor"> +<td class="colFirst"><code>protected <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#readWALEntries-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-">readWALEntries</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream)</code> </td> </tr> -<tr id="i11" class="rowColor"> -<td class="colFirst"><code>private void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#removeEntryFromStream-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch-">removeEntryFromStream</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream, - <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> batch)</code> </td> -</tr> -<tr id="i12" class="altColor"> +<tr id="i13" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#run--">run</a></span>()</code> </td> </tr> -<tr id="i13" class="rowColor"> +<tr id="i14" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#setReaderRunning-boolean-">setReaderRunning</a></span>(boolean readerRunning)</code> </td> </tr> -<tr id="i14" class="altColor"> +<tr id="i15" class="rowColor"> <td class="colFirst"><code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#take--">take</a></span>()</code> <div class="block">Retrieves the next batch of WAL entries from the queue, waiting up to the specified time for a batch to become available</div> </td> </tr> -<tr id="i15" class="rowColor"> +<tr id="i16" class="altColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#updateBatchStats-org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch-org.apache.hadoop.hbase.wal.WAL.Entry-long-">updateBatchStats</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> batch, <a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry, @@ -388,7 +384,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>LOG</h4> -<pre>private static final org.slf4j.Logger <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.55">LOG</a></pre> +<pre>private static final org.slf4j.Logger <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.54">LOG</a></pre> </li> </ul> <a name="logQueue"> @@ -397,7 +393,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>logQueue</h4> -<pre>private final <a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/PriorityBlockingQueue.html?is-external=true"; title="class or interface in java.util.concurrent">PriorityBlockingQueue</a><org.apache.hadoop.fs.Path> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.57">logQueue</a></pre> +<pre>private final <a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/PriorityBlockingQueue.html?is-external=true"; title="class or interface in java.util.concurrent">PriorityBlockingQueue</a><org.apache.hadoop.fs.Path> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.56">logQueue</a></pre> </li> </ul> <a name="fs"> @@ -406,7 +402,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>fs</h4> -<pre>private final org.apache.hadoop.fs.FileSystem <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.58">fs</a></pre> +<pre>private final org.apache.hadoop.fs.FileSystem <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.57">fs</a></pre> </li> </ul> <a name="conf"> @@ -415,7 +411,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>conf</h4> -<pre>private final org.apache.hadoop.conf.Configuration <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.59">conf</a></pre> +<pre>private final org.apache.hadoop.conf.Configuration <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.58">conf</a></pre> </li> </ul> <a name="filter"> @@ -424,7 +420,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>filter</h4> -<pre>private final <a href="../../../../../../org/apache/hadoop/hbase/replication/WALEntryFilter.html" title="interface in org.apache.hadoop.hbase.replication">WALEntryFilter</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.60">filter</a></pre> +<pre>private final <a href="../../../../../../org/apache/hadoop/hbase/replication/WALEntryFilter.html" title="interface in org.apache.hadoop.hbase.replication">WALEntryFilter</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.59">filter</a></pre> </li> </ul> <a name="source"> @@ -433,7 +429,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>source</h4> -<pre>private final <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSource</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.61">source</a></pre> +<pre>private final <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSource</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.60">source</a></pre> </li> </ul> <a name="entryBatchQueue"> @@ -442,7 +438,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>entryBatchQueue</h4> -<pre>protected final <a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/BlockingQueue.html?is-external=true"; title="class or interface in java.util.concurrent">BlockingQueue</a><<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.63">entryBatchQueue</a></pre> +<pre>protected final <a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/BlockingQueue.html?is-external=true"; title="class or interface in java.util.concurrent">BlockingQueue</a><<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.62">entryBatchQueue</a></pre> </li> </ul> <a name="replicationBatchSizeCapacity"> @@ -451,7 +447,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>replicationBatchSizeCapacity</h4> -<pre>private final long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.65">replicationBatchSizeCapacity</a></pre> +<pre>private final long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.64">replicationBatchSizeCapacity</a></pre> </li> </ul> <a name="replicationBatchCountCapacity"> @@ -460,7 +456,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>replicationBatchCountCapacity</h4> -<pre>protected final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.67">replicationBatchCountCapacity</a></pre> +<pre>private final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.66">replicationBatchCountCapacity</a></pre> </li> </ul> <a name="currentPosition"> @@ -469,7 +465,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>currentPosition</h4> -<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.69">currentPosition</a></pre> +<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.68">currentPosition</a></pre> </li> </ul> <a name="sleepForRetries"> @@ -478,7 +474,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>sleepForRetries</h4> -<pre>private final long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.70">sleepForRetries</a></pre> +<pre>private final long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.69">sleepForRetries</a></pre> </li> </ul> <a name="maxRetriesMultiplier"> @@ -487,7 +483,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>maxRetriesMultiplier</h4> -<pre>private final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.71">maxRetriesMultiplier</a></pre> +<pre>private final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.70">maxRetriesMultiplier</a></pre> </li> </ul> <a name="eofAutoRecovery"> @@ -496,16 +492,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>eofAutoRecovery</h4> -<pre>private final boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.72">eofAutoRecovery</a></pre> -</li> -</ul> -<a name="firstCellInEntryBeforeFiltering"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>firstCellInEntryBeforeFiltering</h4> -<pre>private <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/replication/regionserver/ReplicationSourceWALReader.html#line.79">firstCellInEntryBeforeFiltering</a></pre> +<pre>private final boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.71">eofAutoRecovery</a></pre> </li> </ul> <a name="isReaderRunning"> @@ -514,7 +501,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>isReaderRunning</h4> -<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.82">isReaderRunning</a></pre> +<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.74">isReaderRunning</a></pre> </li> </ul> <a name="totalBufferUsed"> @@ -523,25 +510,16 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>totalBufferUsed</h4> -<pre>private <a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicLong</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.84">totalBufferUsed</a></pre> +<pre>private <a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicLong</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.76">totalBufferUsed</a></pre> </li> </ul> <a name="totalBufferQuota"> <!-- --> </a> -<ul class="blockList"> -<li class="blockList"> -<h4>totalBufferQuota</h4> -<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.85">totalBufferQuota</a></pre> -</li> -</ul> -<a name="serialReplicationChecker"> -<!-- --> -</a> <ul class="blockListLast"> <li class="blockList"> -<h4>serialReplicationChecker</h4> -<pre>private final <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/SerialReplicationChecker.html" title="class in org.apache.hadoop.hbase.replication.regionserver">SerialReplicationChecker</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.87">serialReplicationChecker</a></pre> +<h4>totalBufferQuota</h4> +<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.77">totalBufferQuota</a></pre> </li> </ul> </li> @@ -558,7 +536,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockListLast"> <li class="blockList"> <h4>ReplicationSourceWALReader</h4> -<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.99">ReplicationSourceWALReader</a>(org.apache.hadoop.fs.FileSystem fs, +<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.89">ReplicationSourceWALReader</a>(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf, <a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/PriorityBlockingQueue.html?is-external=true"; title="class or interface in java.util.concurrent">PriorityBlockingQueue</a><org.apache.hadoop.fs.Path> logQueue, long startPosition, @@ -591,7 +569,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>run</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.132">run</a>()</pre> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.121">run</a>()</pre> <dl> <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true#run--"; title="class or interface in java.lang">run</a></code> in interface <code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true"; title="class or interface in java.lang">Runnable</a></code></dd> @@ -600,19 +578,14 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html </dl> </li> </ul> -<a name="removeEntryFromStream-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch-"> +<a name="addEntryToBatch-org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch-org.apache.hadoop.hbase.wal.WAL.Entry-"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> -<h4>removeEntryFromStream</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.172">removeEntryFromStream</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream, - <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> batch) - throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> -<dl> -<dt><span class="throwsLabel">Throws:</span></dt> -<dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code></dd> -</dl> +<h4>addEntryToBatch</h4> +<pre>protected final boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.162">addEntryToBatch</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> batch, + <a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</pre> </li> </ul> <a name="readWALEntries-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-"> @@ -621,9 +594,9 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>readWALEntries</h4> -<pre>private <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.179">readWALEntries</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream) - throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a>, - <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> +<pre>protected <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.176">readWALEntries</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream) + throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a>, + <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code></dd> @@ -637,7 +610,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>handleEmptyWALEntryBatch</h4> -<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.246">handleEmptyWALEntryBatch</a>(org.apache.hadoop.fs.Path currentPath) +<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.195">handleEmptyWALEntryBatch</a>(org.apache.hadoop.fs.Path currentPath) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -651,7 +624,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>handleEofException</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.254">handleEofException</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a> e)</pre> +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.203">handleEofException</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a> e)</pre> </li> </ul> <a name="getCurrentPath--"> @@ -660,7 +633,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>getCurrentPath</h4> -<pre>public org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.269">getCurrentPath</a>()</pre> +<pre>public org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.218">getCurrentPath</a>()</pre> </li> </ul> <a name="checkQuota--"> @@ -669,7 +642,16 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>checkQuota</h4> -<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.280">checkQuota</a>()</pre> +<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.229">checkQuota</a>()</pre> +</li> +</ul> +<a name="createBatch-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>createBatch</h4> +<pre>protected final <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.238">createBatch</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream)</pre> </li> </ul> <a name="filterEntry-org.apache.hadoop.hbase.wal.WAL.Entry-"> @@ -678,7 +660,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>filterEntry</h4> -<pre>private <a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.289">filterEntry</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</pre> +<pre>protected final <a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.242">filterEntry</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</pre> </li> </ul> <a name="take--"> @@ -687,7 +669,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>take</h4> -<pre>public <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.303">take</a>() +<pre>public <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.256">take</a>() throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> <div class="block">Retrieves the next batch of WAL entries from the queue, waiting up to the specified time for a batch to become available</div> @@ -705,7 +687,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>getEntrySize</h4> -<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.307">getEntrySize</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</pre> +<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.260">getEntrySize</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</pre> </li> </ul> <a name="updateBatchStats-org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch-org.apache.hadoop.hbase.wal.WAL.Entry-long-"> @@ -714,7 +696,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>updateBatchStats</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.312">updateBatchStats</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> batch, +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.265">updateBatchStats</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> batch, <a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry, long entrySize)</pre> </li> @@ -725,7 +707,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>countDistinctRowKeysAndHFiles</h4> -<pre>private <a href="../../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>,<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.326">countDistinctRowKeysAndHFiles</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a> edit)</pre> +<pre>private <a href="../../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>,<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.279">countDistinctRowKeysAndHFiles</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a> edit)</pre> <div class="block">Count the number of different row keys in the given edit because of mini-batching. We assume that there's at least one Cell in the WALEdit.</div> <dl> @@ -742,7 +724,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>calculateTotalSizeOfStoreFiles</h4> -<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.364">calculateTotalSizeOfStoreFiles</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a> edit)</pre> +<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.317">calculateTotalSizeOfStoreFiles</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a> edit)</pre> <div class="block">Calculate the total size of all the store files</div> <dl> <dt><span class="paramLabel">Parameters:</span></dt> @@ -758,7 +740,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>acquireBufferQuota</h4> -<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.394">acquireBufferQuota</a>(long size)</pre> +<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.347">acquireBufferQuota</a>(long size)</pre> <dl> <dt><span class="paramLabel">Parameters:</span></dt> <dd><code>size</code> - delta size for grown buffer</dd> @@ -773,7 +755,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>isReaderRunning</h4> -<pre>public boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.401">isReaderRunning</a>()</pre> +<pre>public boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.354">isReaderRunning</a>()</pre> <dl> <dt><span class="returnLabel">Returns:</span></dt> <dd>whether the reader thread is running</dd> @@ -786,7 +768,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockListLast"> <li class="blockList"> <h4>setReaderRunning</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.408">setReaderRunning</a>(boolean readerRunning)</pre> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.361">setReaderRunning</a>(boolean readerRunning)</pre> <dl> <dt><span class="paramLabel">Parameters:</span></dt> <dd><code>readerRunning</code> - the readerRunning to set</dd> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f1b07859/devapidocs/org/apache/hadoop/hbase/replication/regionserver/SerialReplicationChecker.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/SerialReplicationChecker.html b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/SerialReplicationChecker.html index d617297..8214918 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/SerialReplicationChecker.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/SerialReplicationChecker.html @@ -50,7 +50,7 @@ var activeTableTab = "activeTableTab"; <div class="subNav"> <ul class="navList"> <li><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationThrottler.html" title="class in org.apache.hadoop.hbase.replication.regionserver"><span class="typeNameLink">Prev Class</span></a></li> -<li><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/SourceFSConfigurationProvider.html" title="interface in org.apache.hadoop.hbase.replication.regionserver"><span class="typeNameLink">Next Class</span></a></li> +<li><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/SerialReplicationSourceWALReader.html" title="class in org.apache.hadoop.hbase.replication.regionserver"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> <li><a href="../../../../../../index.html?org/apache/hadoop/hbase/replication/regionserver/SerialReplicationChecker.html" target="_top">Frames</a></li> @@ -561,7 +561,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <div class="subNav"> <ul class="navList"> <li><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationThrottler.html" title="class in org.apache.hadoop.hbase.replication.regionserver"><span class="typeNameLink">Prev Class</span></a></li> -<li><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/SourceFSConfigurationProvider.html" title="interface in org.apache.hadoop.hbase.replication.regionserver"><span class="typeNameLink">Next Class</span></a></li> +<li><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/SerialReplicationSourceWALReader.html" title="class in org.apache.hadoop.hbase.replication.regionserver"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> <li><a href="../../../../../../index.html?org/apache/hadoop/hbase/replication/regionserver/SerialReplicationChecker.html" target="_top">Frames</a></li>
