http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fd35fe02/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html index cc41ea4..df182b1 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html @@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>public static enum <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.49">ReplicationSourceShipper.WorkerState</a> +<pre>public static enum <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.48">ReplicationSourceShipper.WorkerState</a> extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true"; title="class or interface in java.lang">Enum</a><<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html" title="enum in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper.WorkerState</a>></pre> </li> </ul> @@ -213,7 +213,7 @@ the order they are declared.</div> <ul class="blockList"> <li class="blockList"> <h4>RUNNING</h4> -<pre>public static final <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.WorkerState.html#line.50">RUNNING</a></pre> +<pre>public static final <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.WorkerState.html#line.49">RUNNING</a></pre> </li> </ul> <a name="STOPPED"> @@ -222,7 +222,7 @@ the order they are declared.</div> <ul class="blockList"> <li class="blockList"> <h4>STOPPED</h4> -<pre>public static final <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.WorkerState.html#line.51">STOPPED</a></pre> +<pre>public static final <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.WorkerState.html#line.50">STOPPED</a></pre> </li> </ul> <a name="FINISHED"> @@ -231,7 +231,7 @@ the order they are declared.</div> <ul class="blockListLast"> <li class="blockList"> <h4>FINISHED</h4> -<pre>public static final <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.WorkerState.html#line.52">FINISHED</a></pre> +<pre>public static final <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.WorkerState.html#line.51">FINISHED</a></pre> </li> </ul> </li> @@ -248,7 +248,7 @@ the order they are declared.</div> <ul class="blockList"> <li class="blockList"> <h4>values</h4> -<pre>public static <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.WorkerState.html#line.49">values</a>()</pre> +<pre>public static <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.WorkerState.html#line.48">values</a>()</pre> <div class="block">Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows: @@ -268,7 +268,7 @@ for (ReplicationSourceShipper.WorkerState c : ReplicationSourceShipper.WorkerSta <ul class="blockListLast"> <li class="blockList"> <h4>valueOf</h4> -<pre>public static <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.WorkerState.html#line.49">valueOf</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> name)</pre> +<pre>public static <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.WorkerState.html#line.48">valueOf</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> name)</pre> <div class="block">Returns the enum constant of this type with the specified name. The string must match <i>exactly</i> an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fd35fe02/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 46e0c1a..2e76480 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,"i16":10,"i17":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}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -123,7 +123,7 @@ var activeTableTab = "activeTableTab"; <hr> <br> <pre>@InterfaceAudience.Private -public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.45">ReplicationSourceShipper</a> +public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.44">ReplicationSourceShipper</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">This thread reads entries from a queue and ships them. Entries are placed onto the queue by ReplicationSourceWALReaderThread</div> @@ -172,20 +172,20 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <th class="colLast" scope="col">Field and Description</th> </tr> <tr class="altColor"> -<td class="colFirst"><code>protected org.apache.hadoop.conf.Configuration</code></td> +<td class="colFirst"><code>private org.apache.hadoop.conf.Configuration</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#conf">conf</a></span></code> </td> </tr> <tr class="rowColor"> -<td class="colFirst"><code>protected org.apache.hadoop.fs.Path</code></td> +<td class="colFirst"><code>private org.apache.hadoop.fs.Path</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#currentPath">currentPath</a></span></code> </td> </tr> <tr class="altColor"> -<td class="colFirst"><code>protected <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader</a></code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#entryReader">entryReader</a></span></code> </td> +<td class="colFirst"><code>private long</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#currentPosition">currentPosition</a></span></code> </td> </tr> <tr class="rowColor"> -<td class="colFirst"><code>protected long</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#lastLoggedPosition">lastLoggedPosition</a></span></code> </td> +<td class="colFirst"><code>protected <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#entryReader">entryReader</a></span></code> </td> </tr> <tr class="altColor"> <td class="colFirst"><code>private static org.slf4j.Logger</code></td> @@ -204,7 +204,7 @@ 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#sleepForRetries">sleepForRetries</a></span></code> </td> </tr> <tr class="altColor"> -<td class="colFirst"><code>protected <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html" title="interface in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a></code></td> +<td class="colFirst"><code>private <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html" title="interface in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#source">source</a></span></code> </td> </tr> <tr class="rowColor"> @@ -262,78 +262,69 @@ 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#cleanUpHFileRefs-org.apache.hadoop.hbase.wal.WALEdit-">cleanUpHFileRefs</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a> edit)</code> </td> </tr> <tr id="i1" class="rowColor"> -<td class="colFirst"><code>org.apache.hadoop.fs.Path</code></td> +<td class="colFirst"><code>(package private) org.apache.hadoop.fs.Path</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#getCurrentPath--">getCurrentPath</a></span>()</code> </td> </tr> <tr id="i2" class="altColor"> -<td class="colFirst"><code>long</code></td> +<td class="colFirst"><code>(package private) long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#getCurrentPosition--">getCurrentPosition</a></span>()</code> </td> </tr> <tr id="i3" class="rowColor"> -<td class="colFirst"><code><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/ReplicationSourceShipper.html#getLogQueue--">getLogQueue</a></span>()</code> </td> -</tr> -<tr id="i4" class="altColor"> -<td class="colFirst"><code>long</code></td> +<td class="colFirst"><code>(package private) long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#getStartPosition--">getStartPosition</a></span>()</code> </td> </tr> -<tr id="i5" class="rowColor"> -<td class="colFirst"><code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html" title="enum in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper.WorkerState</a></code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#getWorkerState--">getWorkerState</a></span>()</code> </td> -</tr> -<tr id="i6" class="altColor"> -<td class="colFirst"><code>protected boolean</code></td> +<tr id="i4" 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/ReplicationSourceShipper.html#isActive--">isActive</a></span>()</code> </td> </tr> -<tr id="i7" class="rowColor"> +<tr id="i5" class="rowColor"> <td class="colFirst"><code>boolean</code></td> <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"> +<tr id="i6" 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> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#noMoreData--">noMoreData</a></span>()</code> </td> </tr> -<tr id="i9" class="rowColor"> +<tr id="i7" 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> +<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="i10" class="altColor"> +<tr id="i8" 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="i11" class="rowColor"> -<td class="colFirst"><code>void</code></td> +<tr id="i9" class="rowColor"> +<td class="colFirst"><code>(package private) 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="i12" class="altColor"> -<td class="colFirst"><code>void</code></td> +<tr id="i10" 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#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="i13" class="rowColor"> -<td class="colFirst"><code>protected void</code></td> +<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/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="i14" class="altColor"> +<tr id="i12" 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="i15" class="rowColor"> +<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/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="i16" class="altColor"> -<td class="colFirst"><code>void</code></td> +<tr id="i14" class="altColor"> +<td class="colFirst"><code>(package private) 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="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> +<tr id="i15" 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/ReplicationSourceShipper.html#updateLogPosition-org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch-">updateLogPosition</a></span>(<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> </table> <ul class="blockList"> @@ -370,7 +361,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/ReplicationSourceShipper.html#line.46">LOG</a></pre> +<pre>private static final org.slf4j.Logger <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.45">LOG</a></pre> </li> </ul> <a name="conf"> @@ -379,7 +370,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>protected final org.apache.hadoop.conf.Configuration <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.55">conf</a></pre> +<pre>private final org.apache.hadoop.conf.Configuration <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.54">conf</a></pre> </li> </ul> <a name="walGroupId"> @@ -388,7 +379,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>walGroupId</h4> -<pre>protected final <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="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.56">walGroupId</a></pre> +<pre>protected final <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="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.55">walGroupId</a></pre> </li> </ul> <a name="queue"> @@ -397,7 +388,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>queue</h4> -<pre>protected 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/ReplicationSourceShipper.html#line.57">queue</a></pre> +<pre>protected 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/ReplicationSourceShipper.html#line.56">queue</a></pre> </li> </ul> <a name="source"> @@ -406,16 +397,16 @@ 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>protected final <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html" title="interface in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.58">source</a></pre> +<pre>private final <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html" title="interface in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.57">source</a></pre> </li> </ul> -<a name="lastLoggedPosition"> +<a name="currentPosition"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> -<h4>lastLoggedPosition</h4> -<pre>protected long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.61">lastLoggedPosition</a></pre> +<h4>currentPosition</h4> +<pre>private volatile long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.61">currentPosition</a></pre> </li> </ul> <a name="currentPath"> @@ -424,7 +415,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>currentPath</h4> -<pre>protected volatile org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.63">currentPath</a></pre> +<pre>private org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.63">currentPath</a></pre> </li> </ul> <a name="state"> @@ -433,7 +424,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>state</h4> -<pre>private <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.65">state</a></pre> +<pre>private volatile <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.65">state</a></pre> </li> </ul> <a name="entryReader"> @@ -506,13 +497,13 @@ 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 name="noMoreData--"> <!-- --> </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> +<h4>noMoreData</h4> +<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.120">noMoreData</a>()</pre> </li> </ul> <a name="postFinish--"> @@ -521,7 +512,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <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> +<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.124">postFinish</a>()</pre> </li> </ul> <a name="shipEdits-org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch-"> @@ -530,7 +521,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <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.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> +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.130">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> @@ -540,7 +531,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.203">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.200">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> @@ -548,14 +539,13 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html </dl> </li> </ul> -<a name="updateLogPosition-long-java.util.Map-"> +<a name="updateLogPosition-org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch-"> <!-- --> </a> <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.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> +<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.224">updateLogPosition</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> batch)</pre> </li> </ul> <a name="startup-java.lang.Thread.UncaughtExceptionHandler-"> @@ -564,16 +554,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.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--"> -<!-- --> -</a> -<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.239">getLogQueue</a>()</pre> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.249">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="getCurrentPath--"> @@ -582,7 +563,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.243">getCurrentPath</a>()</pre> +<pre>org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.255">getCurrentPath</a>()</pre> </li> </ul> <a name="getCurrentPosition--"> @@ -591,7 +572,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.247">getCurrentPosition</a>()</pre> +<pre>long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.259">getCurrentPosition</a>()</pre> </li> </ul> <a name="setWALReader-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader-"> @@ -600,7 +581,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.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> +<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.263">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--"> @@ -609,7 +590,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.255">getStartPosition</a>()</pre> +<pre>long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.267">getStartPosition</a>()</pre> </li> </ul> <a name="isActive--"> @@ -618,7 +599,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.259">isActive</a>()</pre> +<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.271">isActive</a>()</pre> </li> </ul> <a name="setWorkerState-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceShipper.WorkerState-"> @@ -627,16 +608,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.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--"> -<!-- --> -</a> -<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.267">getWorkerState</a>()</pre> +<pre>protected final void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.275">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="stopWorker--"> @@ -645,7 +617,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.271">stopWorker</a>()</pre> +<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.279">stopWorker</a>()</pre> </li> </ul> <a name="isFinished--"> @@ -654,7 +626,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.275">isFinished</a>()</pre> +<pre>public boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.283">isFinished</a>()</pre> </li> </ul> <a name="sleepForRetries-java.lang.String-int-"> @@ -663,7 +635,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.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, +<pre>public boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.293">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/fd35fe02/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 dfd64bd..520ee41 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html @@ -18,8 +18,8 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10}; -var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; +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":9,"i16":10,"i17":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"; var tableTab = "tableTab"; @@ -170,7 +170,7 @@ 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#currentPosition">currentPosition</a></span></code> </td> </tr> <tr class="altColor"> -<td class="colFirst"><code>protected <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>></code></td> +<td class="colFirst"><code>private <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>></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#entryBatchQueue">entryBatchQueue</a></span></code> </td> </tr> <tr class="rowColor"> @@ -266,7 +266,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html </a> <h3>Method Summary</h3> <table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation"> -<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption> +<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t1" class="tableTab"><span><a href="javascript:show(1);">Static Methods</a></span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption> <tr> <th class="colFirst" scope="col">Modifier and Type</th> <th class="colLast" scope="col">Method and Description</th> @@ -313,7 +313,7 @@ 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#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="i9" class="rowColor"> -<td class="colFirst"><code>protected void</code></td> +<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#handleEmptyWALEntryBatch-org.apache.hadoop.fs.Path-">handleEmptyWALEntryBatch</a></span>(org.apache.hadoop.fs.Path currentPath)</code> </td> </tr> <tr id="i10" class="altColor"> @@ -337,13 +337,18 @@ 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#setReaderRunning-boolean-">setReaderRunning</a></span>(boolean readerRunning)</code> </td> </tr> <tr id="i15" class="rowColor"> +<td class="colFirst"><code>protected static boolean</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#switched-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-org.apache.hadoop.fs.Path-">switched</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream, + org.apache.hadoop.fs.Path path)</code> </td> +</tr> +<tr id="i16" class="altColor"> <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="i16" class="altColor"> +<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/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, @@ -438,7 +443,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.62">entryBatchQueue</a></pre> +<pre>private 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"> @@ -588,13 +593,23 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <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="switched-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-org.apache.hadoop.fs.Path-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>switched</h4> +<pre>protected static final boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.176">switched</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream, + org.apache.hadoop.fs.Path path)</pre> +</li> +</ul> <a name="readWALEntries-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>readWALEntries</h4> -<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) +<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.180">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> @@ -610,8 +625,8 @@ 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.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> +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.222">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> <dd><code><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></code></dd> @@ -624,7 +639,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.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> +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.237">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--"> @@ -633,7 +648,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.218">getCurrentPath</a>()</pre> +<pre>public org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.252">getCurrentPath</a>()</pre> </li> </ul> <a name="checkQuota--"> @@ -642,7 +657,7 @@ 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.229">checkQuota</a>()</pre> +<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.263">checkQuota</a>()</pre> </li> </ul> <a name="createBatch-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-"> @@ -651,7 +666,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <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> +<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.272">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-"> @@ -660,7 +675,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>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> +<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.276">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--"> @@ -669,7 +684,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.256">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.290">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> @@ -687,7 +702,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.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> +<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.294">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-"> @@ -696,7 +711,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.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, +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.299">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> @@ -707,7 +722,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.279">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.313">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> @@ -724,7 +739,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.317">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.351">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> @@ -740,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>acquireBufferQuota</h4> -<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.347">acquireBufferQuota</a>(long size)</pre> +<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.381">acquireBufferQuota</a>(long size)</pre> <dl> <dt><span class="paramLabel">Parameters:</span></dt> <dd><code>size</code> - delta size for grown buffer</dd> @@ -755,7 +770,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.354">isReaderRunning</a>()</pre> +<pre>public boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.388">isReaderRunning</a>()</pre> <dl> <dt><span class="returnLabel">Returns:</span></dt> <dd>whether the reader thread is running</dd> @@ -768,7 +783,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.361">setReaderRunning</a>(boolean readerRunning)</pre> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.395">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/fd35fe02/devapidocs/org/apache/hadoop/hbase/replication/regionserver/SerialReplicationSourceWALReader.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/SerialReplicationSourceWALReader.html b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/SerialReplicationSourceWALReader.html index 66b9039..92145a9 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/SerialReplicationSourceWALReader.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/SerialReplicationSourceWALReader.html @@ -170,13 +170,6 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/replication/regionser </tr> </table> <ul class="blockList"> -<li class="blockList"><a name="fields.inherited.from.class.org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader"> -<!-- --> -</a> -<h3>Fields inherited from class org.apache.hadoop.hbase.replication.regionserver.<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader</a></h3> -<code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#entryBatchQueue">entryBatchQueue</a></code></li> -</ul> -<ul class="blockList"> <li class="blockList"><a name="fields.inherited.from.class.java.lang.Thread"> <!-- --> </a> @@ -234,7 +227,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/replication/regionser <!-- --> </a> <h3>Methods inherited from class org.apache.hadoop.hbase.replication.regionserver.<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader</a></h3> -<code><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>, <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#createBatch-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-">createBatch</a>, <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#filterEntry-org.apache.hadoop.hbase.wal.WAL.Entry-">filterEntry</a>, <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#getCurrentPath--">getCurrentPath</a>, <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#handleEmptyWALEntryBatch-org.apache.hadoop.fs.Path-">handleEmptyWALEntryBatch</a>, <a href="../../../../../.. /org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#isReaderRunning--">isReaderRunning</a>, <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#run--">run</a>, <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#setReaderRunning-boolean-">setReaderRunning</a>, <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#take--">take</a></code></li> +<code><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>, <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#createBatch-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-">createBatch</a>, <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#filterEntry-org.apache.hadoop.hbase.wal.WAL.Entry-">filterEntry</a>, <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#getCurrentPath--">getCurrentPath</a>, <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#isReaderRunning--">isReaderRunning</a>, <a href="../../../../../../org/apache/hadoop/hbase/replication/region server/ReplicationSourceWALReader.html#run--">run</a>, <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#setReaderRunning-boolean-">setReaderRunning</a>, <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#switched-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-org.apache.hadoop.fs.Path-">switched</a>, <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#take--">take</a></code></li> </ul> <ul class="blockList"> <li class="blockList"><a name="methods.inherited.from.class.java.lang.Thread"> @@ -336,7 +329,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/replication/regionser <ul class="blockListLast"> <li class="blockList"> <h4>removeEntryFromStream</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/SerialReplicationSourceWALReader.html#line.106">removeEntryFromStream</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream, +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/SerialReplicationSourceWALReader.html#line.129">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>
