[23/51] [partial] hbase-site git commit: Published site at 0f23784182ab88649de340d75804e0ff20dcd0fc.

[git-site-role]

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/bcb555af/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html
----------------------------------------------------------------------
diff --git 
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html
 
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html
index 432cba4..8851d0f 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.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,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":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,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10};
 var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],8:["t4","Concrete Methods"]};
 var altColor = "altColor";
 var rowColor = "rowColor";
@@ -118,7 +118,7 @@ var activeTableTab = "activeTableTab";
 <hr>
 <br>
 <pre>@InterfaceAudience.Private
-public class <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.80">ReplicationSource</a>
+public class <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.84">ReplicationSource</a>
 extends <a 
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">Object</a>
 implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a></pre>
 <div class="block">Class that handles the source of a replication stream.
@@ -369,55 +369,65 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 </td>
 </tr>
 <tr id="i9" 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/ReplicationSource.html#getFileSize-org.apache.hadoop.fs.Path-">getFileSize</a></span>(org.apache.hadoop.fs.Path&nbsp;currentPath)</code>&nbsp;</td>
+</tr>
+<tr id="i10" class="altColor">
 <td class="colFirst"><code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeer.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationPeer</a></code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getPeer--">getPeer</a></span>()</code>
 <div class="block">Get the replication peer instance.</div>
 </td>
 </tr>
-<tr id="i10" class="altColor">
+<tr id="i11" class="rowColor">
 <td class="colFirst"><code><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></code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getQueueId--">getQueueId</a></span>()</code>
 <div class="block">Get the queue id that the source is replicating to</div>
 </td>
 </tr>
-<tr id="i11" class="rowColor">
+<tr id="i12" class="altColor">
 <td class="colFirst"><code>(package private) <a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueStorage.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationQueueStorage</a></code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getQueueStorage--">getQueueStorage</a></span>()</code>&nbsp;</td>
 </tr>
-<tr id="i12" class="altColor">
+<tr id="i13" class="rowColor">
 <td class="colFirst"><code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationEndpoint.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationEndpoint</a></code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getReplicationEndpoint--">getReplicationEndpoint</a></span>()</code>&nbsp;</td>
 </tr>
-<tr id="i13" class="rowColor">
+<tr id="i14" class="altColor">
 <td class="colFirst"><code>(package private) <a 
href="../../../../../../org/apache/hadoop/hbase/Server.html" title="interface 
in org.apache.hadoop.hbase">Server</a></code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getServer--">getServer</a></span>()</code>&nbsp;</td>
 </tr>
-<tr id="i14" class="altColor">
+<tr id="i15" class="rowColor">
 <td class="colFirst"><code><a 
href="../../../../../../org/apache/hadoop/hbase/ServerName.html" title="class 
in org.apache.hadoop.hbase">ServerName</a></code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getServerWALsBelongTo--">getServerWALsBelongTo</a></span>()</code>
 <div class="block">The queue of WALs only belong to one region server.</div>
 </td>
 </tr>
-<tr id="i15" class="rowColor">
+<tr id="i16" class="altColor">
 <td class="colFirst"><code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a></code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getSourceManager--">getSourceManager</a></span>()</code>&nbsp;</td>
 </tr>
-<tr id="i16" class="altColor">
+<tr id="i17" class="rowColor">
 <td class="colFirst"><code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">MetricsSource</a></code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getSourceMetrics--">getSourceMetrics</a></span>()</code>&nbsp;</td>
 </tr>
-<tr id="i17" class="rowColor">
+<tr id="i18" class="altColor">
 <td class="colFirst"><code><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></code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getStats--">getStats</a></span>()</code>
 <div class="block">Get a string representation of the current statistics
  for this source</div>
 </td>
 </tr>
-<tr id="i18" class="altColor">
+<tr id="i19" class="rowColor">
 <td class="colFirst"><code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALFileLengthProvider.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">WALFileLengthProvider</a></code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getWALFileLengthProvider--">getWALFileLengthProvider</a></span>()</code>&nbsp;</td>
 </tr>
-<tr id="i19" class="rowColor">
+<tr id="i20" class="altColor">
+<td class="colFirst"><code><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>&lt;<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="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationStatus.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationStatus</a>&gt;</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getWalGroupStatus--">getWalGroupStatus</a></span>()</code>
+<div class="block">get the stat of replication for each wal group.</div>
+</td>
+</tr>
+<tr id="i21" class="rowColor">
 <td class="colFirst"><code>void</code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#init-org.apache.hadoop.conf.Configuration-org.apache.hadoop.fs.FileSystem-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager-org.apache.hadoop.hbase.replication.ReplicationQueueStorage-org.apache.hadoop.hbase.replication.ReplicationPeer-org.apache.hadoop.hbase.Server-java.lang.String-java.util.UUID-org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider-org.apache.hadoop.hbase.replication.regionserver.MetricsSource-">init</a></span>(org.apache.hadoop.conf.Configuration&nbsp;conf,
     org.apache.hadoop.fs.FileSystem&nbsp;fs,
@@ -432,77 +442,77 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <div class="block">Instantiation method used by region servers</div>
 </td>
 </tr>
-<tr id="i20" class="altColor">
+<tr id="i22" 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/ReplicationSource.html#initAndStartReplicationEndpoint-org.apache.hadoop.hbase.replication.ReplicationEndpoint-">initAndStartReplicationEndpoint</a></span>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationEndpoint.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationEndpoint</a>&nbsp;replicationEndpoint)</code>&nbsp;</td>
 </tr>
-<tr id="i21" class="rowColor">
+<tr id="i23" 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/ReplicationSource.html#initialize--">initialize</a></span>()</code>&nbsp;</td>
 </tr>
-<tr id="i22" class="altColor">
+<tr id="i24" 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/ReplicationSource.html#initializeWALEntryFilter-java.util.UUID-">initializeWALEntryFilter</a></span>(<a
 
href="https://docs.oracle.com/javase/8/docs/api/java/util/UUID.html?is-external=true";
 title="class or interface in 
java.util">UUID</a>&nbsp;peerClusterId)</code>&nbsp;</td>
 </tr>
-<tr id="i23" class="rowColor">
+<tr id="i25" class="rowColor">
 <td class="colFirst"><code>boolean</code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#isSourceActive--">isSourceActive</a></span>()</code>&nbsp;</td>
 </tr>
-<tr id="i24" class="altColor">
+<tr id="i26" class="altColor">
 <td class="colFirst"><code>void</code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#postShipEdits-java.util.List-int-">postShipEdits</a></span>(<a
 
href="https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List</a>&lt;<a 
href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" 
title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a>&gt;&nbsp;entries,
              int&nbsp;batchSize)</code>
 <div class="block">Call this after the shipper thread ship some entries to 
peer cluster.</div>
 </td>
 </tr>
-<tr id="i25" class="rowColor">
+<tr id="i27" 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/ReplicationSource.html#removeWorker-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceShipper-">removeWorker</a></span>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper</a>&nbsp;worker)</code>&nbsp;</td>
 </tr>
-<tr id="i26" class="altColor">
+<tr id="i28" class="altColor">
 <td class="colFirst"><code>protected boolean</code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.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>&nbsp;msg,
                int&nbsp;sleepMultiplier)</code>
 <div class="block">Do the sleeping logic</div>
 </td>
 </tr>
-<tr id="i27" class="rowColor">
+<tr id="i29" class="rowColor">
 <td class="colFirst"><code>void</code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#startup--">startup</a></span>()</code>
 <div class="block">Start the replication</div>
 </td>
 </tr>
-<tr id="i28" class="altColor">
+<tr id="i30" class="altColor">
 <td class="colFirst"><code>void</code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#terminate-java.lang.String-">terminate</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>&nbsp;reason)</code>
 <div class="block">End the replication</div>
 </td>
 </tr>
-<tr id="i29" class="rowColor">
+<tr id="i31" class="rowColor">
 <td class="colFirst"><code>void</code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#terminate-java.lang.String-java.lang.Exception-">terminate</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>&nbsp;reason,
          <a 
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true";
 title="class or interface in java.lang">Exception</a>&nbsp;cause)</code>
 <div class="block">End the replication</div>
 </td>
 </tr>
-<tr id="i30" class="altColor">
+<tr id="i32" class="altColor">
 <td class="colFirst"><code>void</code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#terminate-java.lang.String-java.lang.Exception-boolean-">terminate</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>&nbsp;reason,
          <a 
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true";
 title="class or interface in java.lang">Exception</a>&nbsp;cause,
          boolean&nbsp;join)</code>&nbsp;</td>
 </tr>
-<tr id="i31" class="rowColor">
+<tr id="i33" 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/ReplicationSource.html#tryStartNewShipper-java.lang.String-java.util.concurrent.PriorityBlockingQueue-">tryStartNewShipper</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>&nbsp;walGroupId,
                   <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>&lt;org.apache.hadoop.fs.Path&gt;&nbsp;queue)</code>&nbsp;</td>
 </tr>
-<tr id="i32" class="altColor">
+<tr id="i34" class="altColor">
 <td class="colFirst"><code>void</code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#tryThrottle-int-">tryThrottle</a></span>(int&nbsp;batchSize)</code>
 <div class="block">Try to throttle when the peer config with a bandwidth</div>
 </td>
 </tr>
-<tr id="i33" class="rowColor">
+<tr id="i35" 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/ReplicationSource.html#uncaughtException-java.lang.Thread-java.lang.Throwable-">uncaughtException</a></span>(<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>&nbsp;t,
                  <a 
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true";
 title="class or interface in java.lang">Throwable</a>&nbsp;e)</code>&nbsp;</td>
@@ -542,7 +552,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>LOG</h4>
-<pre>private static final&nbsp;org.slf4j.Logger <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.82">LOG</a></pre>
+<pre>private static final&nbsp;org.slf4j.Logger <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.86">LOG</a></pre>
 </li>
 </ul>
 <a name="queues">
@@ -551,7 +561,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>queues</h4>
-<pre>private&nbsp;<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>&lt;<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/util/concurrent/PriorityBlockingQueue.html?is-external=true";
 title="class or interface in 
java.util.concurrent">PriorityBlockingQueue</a>&lt;org.apache.hadoop.fs.Path&gt;&gt;
 <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.85">queues</a></pre>
+<pre>private&nbsp;<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>&lt;<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/util/concurrent/PriorityBlockingQueue.html?is-external=true";
 title="class or interface in 
java.util.concurrent">PriorityBlockingQueue</a>&lt;org.apache.hadoop.fs.Path&gt;&gt;
 <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.89">queues</a></pre>
 </li>
 </ul>
 <a name="queueSizePerGroup">
@@ -560,7 +570,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>queueSizePerGroup</h4>
-<pre>protected&nbsp;int <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.87">queueSizePerGroup</a></pre>
+<pre>protected&nbsp;int <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.91">queueSizePerGroup</a></pre>
 </li>
 </ul>
 <a name="queueStorage">
@@ -569,7 +579,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>queueStorage</h4>
-<pre>protected&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueStorage.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationQueueStorage</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.88">queueStorage</a></pre>
+<pre>protected&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueStorage.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationQueueStorage</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.92">queueStorage</a></pre>
 </li>
 </ul>
 <a name="replicationPeer">
@@ -578,7 +588,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>replicationPeer</h4>
-<pre>protected&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeer.html"
 title="interface in org.apache.hadoop.hbase.replication">ReplicationPeer</a> 
<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.89">replicationPeer</a></pre>
+<pre>protected&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeer.html"
 title="interface in org.apache.hadoop.hbase.replication">ReplicationPeer</a> 
<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.93">replicationPeer</a></pre>
 </li>
 </ul>
 <a name="conf">
@@ -587,7 +597,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>conf</h4>
-<pre>protected&nbsp;org.apache.hadoop.conf.Configuration <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.91">conf</a></pre>
+<pre>protected&nbsp;org.apache.hadoop.conf.Configuration <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.95">conf</a></pre>
 </li>
 </ul>
 <a name="replicationQueueInfo">
@@ -596,7 +606,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>replicationQueueInfo</h4>
-<pre>protected&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueInfo.html"
 title="class in org.apache.hadoop.hbase.replication">ReplicationQueueInfo</a> 
<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.92">replicationQueueInfo</a></pre>
+<pre>protected&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueInfo.html"
 title="class in org.apache.hadoop.hbase.replication">ReplicationQueueInfo</a> 
<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.96">replicationQueueInfo</a></pre>
 </li>
 </ul>
 <a name="manager">
@@ -605,7 +615,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>manager</h4>
-<pre>protected&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a> 
<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.95">manager</a></pre>
+<pre>protected&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a> 
<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.99">manager</a></pre>
 </li>
 </ul>
 <a name="server">
@@ -614,7 +624,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>server</h4>
-<pre>protected&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/Server.html" title="interface 
in org.apache.hadoop.hbase">Server</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.97">server</a></pre>
+<pre>protected&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/Server.html" title="interface 
in org.apache.hadoop.hbase">Server</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.101">server</a></pre>
 </li>
 </ul>
 <a name="sleepForRetries">
@@ -623,7 +633,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>sleepForRetries</h4>
-<pre>private&nbsp;long <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.99">sleepForRetries</a></pre>
+<pre>private&nbsp;long <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.103">sleepForRetries</a></pre>
 </li>
 </ul>
 <a name="fs">
@@ -632,7 +642,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>fs</h4>
-<pre>protected&nbsp;org.apache.hadoop.fs.FileSystem <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.100">fs</a></pre>
+<pre>protected&nbsp;org.apache.hadoop.fs.FileSystem <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.104">fs</a></pre>
 </li>
 </ul>
 <a name="clusterId">
@@ -641,7 +651,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>clusterId</h4>
-<pre>private&nbsp;<a 
href="https://docs.oracle.com/javase/8/docs/api/java/util/UUID.html?is-external=true";
 title="class or interface in java.util">UUID</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.102">clusterId</a></pre>
+<pre>private&nbsp;<a 
href="https://docs.oracle.com/javase/8/docs/api/java/util/UUID.html?is-external=true";
 title="class or interface in java.util">UUID</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.106">clusterId</a></pre>
 </li>
 </ul>
 <a name="totalReplicatedEdits">
@@ -650,7 +660,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>totalReplicatedEdits</h4>
-<pre>private&nbsp;<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/ReplicationSource.html#line.104">totalReplicatedEdits</a></pre>
+<pre>private&nbsp;<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/ReplicationSource.html#line.108">totalReplicatedEdits</a></pre>
 </li>
 </ul>
 <a name="queueId">
@@ -659,7 +669,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>queueId</h4>
-<pre>protected&nbsp;<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/ReplicationSource.html#line.106">queueId</a></pre>
+<pre>protected&nbsp;<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/ReplicationSource.html#line.110">queueId</a></pre>
 </li>
 </ul>
 <a name="maxRetriesMultiplier">
@@ -668,7 +678,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>maxRetriesMultiplier</h4>
-<pre>private&nbsp;int <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.108">maxRetriesMultiplier</a></pre>
+<pre>private&nbsp;int <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.112">maxRetriesMultiplier</a></pre>
 </li>
 </ul>
 <a name="sourceRunning">
@@ -677,7 +687,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>sourceRunning</h4>
-<pre>private volatile&nbsp;boolean <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.110">sourceRunning</a></pre>
+<pre>private volatile&nbsp;boolean <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.114">sourceRunning</a></pre>
 </li>
 </ul>
 <a name="metrics">
@@ -686,7 +696,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>metrics</h4>
-<pre>private&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">MetricsSource</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.112">metrics</a></pre>
+<pre>private&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">MetricsSource</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.116">metrics</a></pre>
 </li>
 </ul>
 <a name="logQueueWarnThreshold">
@@ -695,7 +705,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>logQueueWarnThreshold</h4>
-<pre>private&nbsp;int <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.114">logQueueWarnThreshold</a></pre>
+<pre>private&nbsp;int <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.118">logQueueWarnThreshold</a></pre>
 </li>
 </ul>
 <a name="replicationEndpoint">
@@ -704,7 +714,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>replicationEndpoint</h4>
-<pre>private volatile&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationEndpoint.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationEndpoint</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.116">replicationEndpoint</a></pre>
+<pre>private volatile&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationEndpoint.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationEndpoint</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.120">replicationEndpoint</a></pre>
 </li>
 </ul>
 <a name="walEntryFilter">
@@ -713,7 +723,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>walEntryFilter</h4>
-<pre>protected volatile&nbsp;<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/ReplicationSource.html#line.118">walEntryFilter</a></pre>
+<pre>protected volatile&nbsp;<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/ReplicationSource.html#line.122">walEntryFilter</a></pre>
 </li>
 </ul>
 <a name="throttler">
@@ -722,7 +732,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>throttler</h4>
-<pre>private&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationThrottler.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationThrottler</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.120">throttler</a></pre>
+<pre>private&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationThrottler.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationThrottler</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.124">throttler</a></pre>
 </li>
 </ul>
 <a name="defaultBandwidth">
@@ -731,7 +741,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>defaultBandwidth</h4>
-<pre>private&nbsp;long <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.121">defaultBandwidth</a></pre>
+<pre>private&nbsp;long <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.125">defaultBandwidth</a></pre>
 </li>
 </ul>
 <a name="currentBandwidth">
@@ -740,7 +750,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>currentBandwidth</h4>
-<pre>private&nbsp;long <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.122">currentBandwidth</a></pre>
+<pre>private&nbsp;long <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.126">currentBandwidth</a></pre>
 </li>
 </ul>
 <a name="walFileLengthProvider">
@@ -749,7 +759,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>walFileLengthProvider</h4>
-<pre>private&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALFileLengthProvider.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">WALFileLengthProvider</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.123">walFileLengthProvider</a></pre>
+<pre>private&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALFileLengthProvider.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">WALFileLengthProvider</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.127">walFileLengthProvider</a></pre>
 </li>
 </ul>
 <a name="workerThreads">
@@ -758,7 +768,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>workerThreads</h4>
-<pre>protected final&nbsp;<a 
href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentHashMap.html?is-external=true";
 title="class or interface in java.util.concurrent">ConcurrentHashMap</a>&lt;<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="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper</a>&gt;
 <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.125">workerThreads</a></pre>
+<pre>protected final&nbsp;<a 
href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentHashMap.html?is-external=true";
 title="class or interface in java.util.concurrent">ConcurrentHashMap</a>&lt;<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="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper</a>&gt;
 <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.129">workerThreads</a></pre>
 </li>
 </ul>
 <a name="totalBufferUsed">
@@ -767,7 +777,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>totalBufferUsed</h4>
-<pre>private&nbsp;<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/ReplicationSource.html#line.128">totalBufferUsed</a></pre>
+<pre>private&nbsp;<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/ReplicationSource.html#line.132">totalBufferUsed</a></pre>
 </li>
 </ul>
 <a name="WAIT_ON_ENDPOINT_SECONDS">
@@ -776,7 +786,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>WAIT_ON_ENDPOINT_SECONDS</h4>
-<pre>public static final&nbsp;<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/ReplicationSource.html#line.130">WAIT_ON_ENDPOINT_SECONDS</a></pre>
+<pre>public static final&nbsp;<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/ReplicationSource.html#line.134">WAIT_ON_ENDPOINT_SECONDS</a></pre>
 <dl>
 <dt><span class="seeLabel">See Also:</span></dt>
 <dd><a 
href="../../../../../../constant-values.html#org.apache.hadoop.hbase.replication.regionserver.ReplicationSource.WAIT_ON_ENDPOINT_SECONDS">Constant
 Field Values</a></dd>
@@ -789,7 +799,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>DEFAULT_WAIT_ON_ENDPOINT_SECONDS</h4>
-<pre>public static final&nbsp;int <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.132">DEFAULT_WAIT_ON_ENDPOINT_SECONDS</a></pre>
+<pre>public static final&nbsp;int <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.136">DEFAULT_WAIT_ON_ENDPOINT_SECONDS</a></pre>
 <dl>
 <dt><span class="seeLabel">See Also:</span></dt>
 <dd><a 
href="../../../../../../constant-values.html#org.apache.hadoop.hbase.replication.regionserver.ReplicationSource.DEFAULT_WAIT_ON_ENDPOINT_SECONDS">Constant
 Field Values</a></dd>
@@ -802,7 +812,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>waitOnEndpointSeconds</h4>
-<pre>private&nbsp;int <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.133">waitOnEndpointSeconds</a></pre>
+<pre>private&nbsp;int <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.137">waitOnEndpointSeconds</a></pre>
 </li>
 </ul>
 <a name="initThread">
@@ -811,7 +821,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockListLast">
 <li class="blockList">
 <h4>initThread</h4>
-<pre>private&nbsp;<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> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.135">initThread</a></pre>
+<pre>private&nbsp;<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> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.139">initThread</a></pre>
 </li>
 </ul>
 </li>
@@ -828,7 +838,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockListLast">
 <li class="blockList">
 <h4>ReplicationSource</h4>
-<pre>public&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.80">ReplicationSource</a>()</pre>
+<pre>public&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.84">ReplicationSource</a>()</pre>
 </li>
 </ul>
 </li>
@@ -845,7 +855,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>init</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.148">init</a>(org.apache.hadoop.conf.Configuration&nbsp;conf,
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.152">init</a>(org.apache.hadoop.conf.Configuration&nbsp;conf,
                  org.apache.hadoop.fs.FileSystem&nbsp;fs,
                  <a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a>&nbsp;manager,
                  <a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueStorage.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationQueueStorage</a>&nbsp;queueStorage,
@@ -879,7 +889,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>decorateConf</h4>
-<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.182">decorateConf</a>()</pre>
+<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.186">decorateConf</a>()</pre>
 </li>
 </ul>
 <a name="enqueueLog-org.apache.hadoop.fs.Path-">
@@ -888,7 +898,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>enqueueLog</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.190">enqueueLog</a>(org.apache.hadoop.fs.Path&nbsp;log)</pre>
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.194">enqueueLog</a>(org.apache.hadoop.fs.Path&nbsp;log)</pre>
 <div class="block"><span class="descfrmTypeLabel">Description copied from 
interface:&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#enqueueLog-org.apache.hadoop.fs.Path-">ReplicationSourceInterface</a></code></span></div>
 <div class="block">Add a log to the list of logs to replicate</div>
 <dl>
@@ -905,7 +915,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>addHFileRefs</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.219">addHFileRefs</a>(<a
 href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class 
in org.apache.hadoop.hbase">TableName</a>&nbsp;tableName,
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.223">addHFileRefs</a>(<a
 href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class 
in org.apache.hadoop.hbase">TableName</a>&nbsp;tableName,
                          byte[]&nbsp;family,
                          <a 
href="https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List</a>&lt;<a 
href="../../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in 
org.apache.hadoop.hbase.util">Pair</a>&lt;org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path&gt;&gt;&nbsp;pairs)
                   throws <a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html"
 title="class in 
org.apache.hadoop.hbase.replication">ReplicationException</a></pre>
@@ -930,7 +940,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>createReplicationEndpoint</h4>
-<pre>private&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationEndpoint.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationEndpoint</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.241">createReplicationEndpoint</a>()
+<pre>private&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationEndpoint.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationEndpoint</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.245">createReplicationEndpoint</a>()
                                                throws <a 
href="https://docs.oracle.com/javase/8/docs/api/java/lang/InstantiationException.html?is-external=true";
 title="class or interface in java.lang">InstantiationException</a>,
                                                       <a 
href="https://docs.oracle.com/javase/8/docs/api/java/lang/IllegalAccessException.html?is-external=true";
 title="class or interface in java.lang">IllegalAccessException</a>,
                                                       <a 
href="https://docs.oracle.com/javase/8/docs/api/java/lang/ClassNotFoundException.html?is-external=true";
 title="class or interface in java.lang">ClassNotFoundException</a>,
@@ -950,7 +960,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>initAndStartReplicationEndpoint</h4>
-<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.274">initAndStartReplicationEndpoint</a>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationEndpoint.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationEndpoint</a>&nbsp;replicationEndpoint)
+<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.278">initAndStartReplicationEndpoint</a>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationEndpoint.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationEndpoint</a>&nbsp;replicationEndpoint)
                                       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/util/concurrent/TimeoutException.html?is-external=true";
 title="class or interface in java.util.concurrent">TimeoutException</a></pre>
 <dl>
@@ -966,7 +976,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>initializeWALEntryFilter</h4>
-<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.287">initializeWALEntryFilter</a>(<a
 
href="https://docs.oracle.com/javase/8/docs/api/java/util/UUID.html?is-external=true";
 title="class or interface in java.util">UUID</a>&nbsp;peerClusterId)</pre>
+<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.291">initializeWALEntryFilter</a>(<a
 
href="https://docs.oracle.com/javase/8/docs/api/java/util/UUID.html?is-external=true";
 title="class or interface in java.util">UUID</a>&nbsp;peerClusterId)</pre>
 </li>
 </ul>
 <a 
name="tryStartNewShipper-java.lang.String-java.util.concurrent.PriorityBlockingQueue-">
@@ -975,17 +985,48 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>tryStartNewShipper</h4>
-<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.299">tryStartNewShipper</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>&nbsp;walGroupId,
+<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.303">tryStartNewShipper</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>&nbsp;walGroupId,
                                 <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>&lt;org.apache.hadoop.fs.Path&gt;&nbsp;queue)</pre>
 </li>
 </ul>
+<a name="getWalGroupStatus--">
+<!--   -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>getWalGroupStatus</h4>
+<pre>public&nbsp;<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>&lt;<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="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationStatus.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationStatus</a>&gt;&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.320">getWalGroupStatus</a>()</pre>
+<div class="block"><span class="descfrmTypeLabel">Description copied from 
interface:&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getWalGroupStatus--">ReplicationSourceInterface</a></code></span></div>
+<div class="block">get the stat of replication for each wal group.</div>
+<dl>
+<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
+<dd><code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getWalGroupStatus--">getWalGroupStatus</a></code>&nbsp;in
 interface&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a></code></dd>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>stat of replication</dd>
+</dl>
+</li>
+</ul>
+<a name="getFileSize-org.apache.hadoop.fs.Path-">
+<!--   -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>getFileSize</h4>
+<pre>private&nbsp;long&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.352">getFileSize</a>(org.apache.hadoop.fs.Path&nbsp;currentPath)
+                  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>
+</li>
+</ul>
 <a 
name="createNewShipper-java.lang.String-java.util.concurrent.PriorityBlockingQueue-">
 <!--   -->
 </a>
 <ul class="blockList">
 <li class="blockList">
 <h4>createNewShipper</h4>
-<pre>protected&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper</a>&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.315">createNewShipper</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>&nbsp;walGroupId,
+<pre>protected&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper</a>&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.363">createNewShipper</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>&nbsp;walGroupId,
                                                     <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>&lt;org.apache.hadoop.fs.Path&gt;&nbsp;queue)</pre>
 </li>
 </ul>
@@ -995,7 +1036,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>createNewWALReader</h4>
-<pre>private&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader</a>&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.320">createNewWALReader</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>&nbsp;walGroupId,
+<pre>private&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader</a>&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.368">createNewWALReader</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>&nbsp;walGroupId,
                                                       <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>&lt;org.apache.hadoop.fs.Path&gt;&nbsp;queue,
                                                       
long&nbsp;startPosition)</pre>
 </li>
@@ -1006,7 +1047,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>uncaughtException</h4>
-<pre>protected final&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.327">uncaughtException</a>(<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>&nbsp;t,
+<pre>protected final&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.375">uncaughtException</a>(<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>&nbsp;t,
                                        <a 
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true";
 title="class or interface in java.lang">Throwable</a>&nbsp;e)</pre>
 </li>
 </ul>
@@ -1016,7 +1057,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>getReplicationEndpoint</h4>
-<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationEndpoint.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationEndpoint</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.334">getReplicationEndpoint</a>()</pre>
+<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationEndpoint.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationEndpoint</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.382">getReplicationEndpoint</a>()</pre>
 <dl>
 <dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
 <dd><code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getReplicationEndpoint--">getReplicationEndpoint</a></code>&nbsp;in
 interface&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a></code></dd>
@@ -1031,7 +1072,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>getSourceManager</h4>
-<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a>&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.339">getSourceManager</a>()</pre>
+<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a>&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.387">getSourceManager</a>()</pre>
 <dl>
 <dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
 <dd><code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getSourceManager--">getSourceManager</a></code>&nbsp;in
 interface&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a></code></dd>
@@ -1046,7 +1087,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>tryThrottle</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.344">tryThrottle</a>(int&nbsp;batchSize)
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.392">tryThrottle</a>(int&nbsp;batchSize)
                  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"><span class="descfrmTypeLabel">Description copied from 
interface:&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#tryThrottle-int-">ReplicationSourceInterface</a></code></span></div>
 <div class="block">Try to throttle when the peer config with a bandwidth</div>
@@ -1066,7 +1107,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>checkBandwidthChangeAndResetThrottler</h4>
-<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.359">checkBandwidthChangeAndResetThrottler</a>()</pre>
+<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.407">checkBandwidthChangeAndResetThrottler</a>()</pre>
 </li>
 </ul>
 <a name="getCurrentBandwidth--">
@@ -1075,7 +1116,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>getCurrentBandwidth</h4>
-<pre>private&nbsp;long&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.369">getCurrentBandwidth</a>()</pre>
+<pre>private&nbsp;long&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.417">getCurrentBandwidth</a>()</pre>
 </li>
 </ul>
 <a name="sleepForRetries-java.lang.String-int-">
@@ -1084,7 +1125,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>sleepForRetries</h4>
-<pre>protected&nbsp;boolean&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.381">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>&nbsp;msg,
+<pre>protected&nbsp;boolean&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.429">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>&nbsp;msg,
                                   int&nbsp;sleepMultiplier)</pre>
 <div class="block">Do the sleeping logic</div>
 <dl>
@@ -1102,7 +1143,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>initialize</h4>
-<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.394">initialize</a>()</pre>
+<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.442">initialize</a>()</pre>
 </li>
 </ul>
 <a name="startup--">
@@ -1111,7 +1152,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>startup</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.460">startup</a>()</pre>
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.508">startup</a>()</pre>
 <div class="block"><span class="descfrmTypeLabel">Description copied from 
interface:&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#startup--">ReplicationSourceInterface</a></code></span></div>
 <div class="block">Start the replication</div>
 <dl>
@@ -1126,7 +1167,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>terminate</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.470">terminate</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>&nbsp;reason)</pre>
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.518">terminate</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>&nbsp;reason)</pre>
 <div class="block"><span class="descfrmTypeLabel">Description copied from 
interface:&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#terminate-java.lang.String-">ReplicationSourceInterface</a></code></span></div>
 <div class="block">End the replication</div>
 <dl>
@@ -1143,7 +1184,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>terminate</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.475">terminate</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>&nbsp;reason,
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.523">terminate</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>&nbsp;reason,
                       <a 
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true";
 title="class or interface in java.lang">Exception</a>&nbsp;cause)</pre>
 <div class="block"><span class="descfrmTypeLabel">Description copied from 
interface:&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#terminate-java.lang.String-java.lang.Exception-">ReplicationSourceInterface</a></code></span></div>
 <div class="block">End the replication</div>
@@ -1162,7 +1203,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>terminate</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.479">terminate</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>&nbsp;reason,
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.527">terminate</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>&nbsp;reason,
                       <a 
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true";
 title="class or interface in java.lang">Exception</a>&nbsp;cause,
                       boolean&nbsp;join)</pre>
 </li>
@@ -1173,7 +1214,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>getQueueId</h4>
-<pre>public&nbsp;<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>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.543">getQueueId</a>()</pre>
+<pre>public&nbsp;<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>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.591">getQueueId</a>()</pre>
 <div class="block"><span class="descfrmTypeLabel">Description copied from 
interface:&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getQueueId--">ReplicationSourceInterface</a></code></span></div>
 <div class="block">Get the queue id that the source is replicating to</div>
 <dl>
@@ -1190,7 +1231,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>getCurrentPath</h4>
-<pre>public&nbsp;org.apache.hadoop.fs.Path&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.548">getCurrentPath</a>()</pre>
+<pre>public&nbsp;org.apache.hadoop.fs.Path&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.596">getCurrentPath</a>()</pre>
 <div class="block"><span class="descfrmTypeLabel">Description copied from 
interface:&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getCurrentPath--">ReplicationSourceInterface</a></code></span></div>
 <div class="block">Get the current log that's replicated</div>
 <dl>
@@ -1207,7 +1248,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>isSourceActive</h4>
-<pre>public&nbsp;boolean&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.559">isSourceActive</a>()</pre>
+<pre>public&nbsp;boolean&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.607">isSourceActive</a>()</pre>
 <dl>
 <dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
 <dd><code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#isSourceActive--">isSourceActive</a></code>&nbsp;in
 interface&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a></code></dd>
@@ -1222,7 +1263,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>getStats</h4>
-<pre>public&nbsp;<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>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.589">getStats</a>()</pre>
+<pre>public&nbsp;<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>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.637">getStats</a>()</pre>
 <div class="block"><span class="descfrmTypeLabel">Description copied from 
interface:&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getStats--">ReplicationSourceInterface</a></code></span></div>
 <div class="block">Get a string representation of the current statistics
  for this source</div>
@@ -1240,7 +1281,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>getSourceMetrics</h4>
-<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">MetricsSource</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.610">getSourceMetrics</a>()</pre>
+<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">MetricsSource</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.658">getSourceMetrics</a>()</pre>
 <dl>
 <dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
 <dd><code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getSourceMetrics--">getSourceMetrics</a></code>&nbsp;in
 interface&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a></code></dd>
@@ -1255,7 +1296,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>postShipEdits</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.616">postShipEdits</a>(<a
 
href="https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List</a>&lt;<a 
href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" 
title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a>&gt;&nbsp;entries,
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.664">postShipEdits</a>(<a
 
href="https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List</a>&lt;<a 
href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" 
title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a>&gt;&nbsp;entries,
                           int&nbsp;batchSize)</pre>
 <div class="block"><span class="descfrmTypeLabel">Description copied from 
interface:&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#postShipEdits-java.util.List-int-">ReplicationSourceInterface</a></code></span></div>
 <div class="block">Call this after the shipper thread ship some entries to 
peer cluster.</div>
@@ -1274,7 +1315,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>getWALFileLengthProvider</h4>
-<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALFileLengthProvider.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">WALFileLengthProvider</a>&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.625">getWALFileLengthProvider</a>()</pre>
+<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALFileLengthProvider.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">WALFileLengthProvider</a>&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.673">getWALFileLengthProvider</a>()</pre>
 <dl>
 <dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
 <dd><code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getWALFileLengthProvider--">getWALFileLengthProvider</a></code>&nbsp;in
 interface&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a></code></dd>
@@ -1289,7 +1330,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>getServerWALsBelongTo</h4>
-<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/ServerName.html" title="class 
in org.apache.hadoop.hbase">ServerName</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.630">getServerWALsBelongTo</a>()</pre>
+<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/ServerName.html" title="class 
in org.apache.hadoop.hbase">ServerName</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.678">getServerWALsBelongTo</a>()</pre>
 <div class="block"><span class="descfrmTypeLabel">Description copied from 
interface:&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getServerWALsBelongTo--">ReplicationSourceInterface</a></code></span></div>
 <div class="block">The queue of WALs only belong to one region server. This 
will return the server name which all
  WALs belong to.</div>
@@ -1307,7 +1348,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>getPeer</h4>
-<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeer.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationPeer</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.635">getPeer</a>()</pre>
+<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeer.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationPeer</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.683">getPeer</a>()</pre>
 <div class="block"><span class="descfrmTypeLabel">Description copied from 
interface:&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getPeer--">ReplicationSourceInterface</a></code></span></div>
 <div class="block">Get the replication peer instance.</div>
 <dl>
@@ -1324,7 +1365,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>getServer</h4>
-<pre><a href="../../../../../../org/apache/hadoop/hbase/Server.html" 
title="interface in org.apache.hadoop.hbase">Server</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.639">getServer</a>()</pre>
+<pre><a href="../../../../../../org/apache/hadoop/hbase/Server.html" 
title="interface in org.apache.hadoop.hbase">Server</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.687">getServer</a>()</pre>
 </li>
 </ul>
 <a name="getQueueStorage--">
@@ -1333,7 +1374,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockList">
 <li class="blockList">
 <h4>getQueueStorage</h4>
-<pre><a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueStorage.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationQueueStorage</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.643">getQueueStorage</a>()</pre>
+<pre><a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueStorage.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationQueueStorage</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.691">getQueueStorage</a>()</pre>
 </li>
 </ul>
 <a 
name="removeWorker-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceShipper-">
@@ -1342,7 +1383,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/region
 <ul class="blockListLast">
 <li class="blockList">
 <h4>removeWorker</h4>
-<pre>void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.647">removeWorker</a>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper</a>&nbsp;worker)</pre>
+<pre>void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.695">removeWorker</a>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html"
 title="class in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper</a>&nbsp;worker)</pre>
 </li>
 </ul>
 </li>