http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b9722a17/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html
----------------------------------------------------------------------
diff --git
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html
index a1e5ded..e18c93f 100644
---
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html
+++
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.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};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],8:["t4","Concrete Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -114,7 +114,7 @@ var activeTableTab = "activeTableTab";
<hr>
<br>
<pre>@InterfaceAudience.Private
-public class <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.92">ReplicationSourceManager</a>
+public class <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.91">ReplicationSourceManager</a>
extends <a
href="http://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/ReplicationListener.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationListener</a></pre>
<div class="block">This class is responsible to manage all the replication
@@ -411,53 +411,57 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
</td>
</tr>
<tr id="i16" class="altColor">
+<td class="colFirst"><code>(package private) int</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#getSizeOfLatestPath--">getSizeOfLatestPath</a></span>()</code> </td>
+</tr>
+<tr id="i17" class="rowColor">
<td class="colFirst"><code><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/ReplicationSourceManager.html#getSource-java.lang.String-">getSource</a></span>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> peerId)</code>
<div class="block">Get the normal source for a given peer</div>
</td>
</tr>
-<tr id="i17" class="rowColor">
+<tr id="i18" class="altColor">
<td class="colFirst"><code><a
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<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/ReplicationSourceManager.html#getSources--">getSources</a></span>()</code>
<div class="block">Get a list of all the normal sources of this rs</div>
</td>
</tr>
-<tr id="i18" class="altColor">
+<tr id="i19" class="rowColor">
<td class="colFirst"><code><a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#getStats--">getStats</a></span>()</code>
<div class="block">Get a string representation of all the sources'
metrics</div>
</td>
</tr>
-<tr id="i19" class="rowColor">
+<tr id="i20" class="altColor">
<td class="colFirst"><code><a
href="http://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></code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#getTotalBufferUsed--">getTotalBufferUsed</a></span>()</code> </td>
</tr>
-<tr id="i20" class="altColor">
+<tr id="i21" class="rowColor">
<td class="colFirst"><code>(package private) <a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
title="class or interface in java.util">SortedSet</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>>>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#getWALs--">getWALs</a></span>()</code>
<div class="block">Get a copy of the wals of the first source on this rs</div>
</td>
</tr>
-<tr id="i21" class="rowColor">
+<tr id="i22" class="altColor">
<td class="colFirst"><code>(package private) <a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
title="class or interface in java.util">SortedSet</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>>>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#getWalsByIdRecoveredQueues--">getWalsByIdRecoveredQueues</a></span>()</code>
<div class="block">Get a copy of the wals of the recovered sources on this
rs</div>
</td>
</tr>
-<tr id="i22" class="altColor">
+<tr id="i23" 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/ReplicationSourceManager.html#init--">init</a></span>()</code>
<div class="block">Adds a normal source per registered peer cluster and tries
to process all
old region server wal queues</div>
</td>
</tr>
-<tr id="i23" class="rowColor">
+<tr id="i24" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#join--">join</a></span>()</code>
<div class="block">Terminate the replication on this region server</div>
</td>
</tr>
-<tr id="i24" class="altColor">
+<tr id="i25" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#logPositionAndCleanOldLogs-org.apache.hadoop.fs.Path-java.lang.String-long-boolean-boolean-">logPositionAndCleanOldLogs</a></span>(org.apache.hadoop.fs.Path log,
<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> id,
@@ -469,52 +473,52 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
position.</div>
</td>
</tr>
-<tr id="i25" class="rowColor">
+<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/ReplicationSourceManager.html#peerListChanged-java.util.List-">peerListChanged</a></span>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>> peerIds)</code>
<div class="block">The list of registered peer clusters has changed.</div>
</td>
</tr>
-<tr id="i26" class="altColor">
+<tr id="i27" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#peerRemoved-java.lang.String-">peerRemoved</a></span>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> peerId)</code>
<div class="block">A peer cluster has been removed (i.e.</div>
</td>
</tr>
-<tr id="i27" class="rowColor">
+<tr id="i28" 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/ReplicationSourceManager.html#postLogRoll-org.apache.hadoop.fs.Path-">postLogRoll</a></span>(org.apache.hadoop.fs.Path newLog)</code> </td>
</tr>
-<tr id="i28" class="altColor">
+<tr id="i29" 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/ReplicationSourceManager.html#preLogRoll-org.apache.hadoop.fs.Path-">preLogRoll</a></span>(org.apache.hadoop.fs.Path newLog)</code> </td>
</tr>
-<tr id="i29" class="rowColor">
+<tr id="i30" 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/ReplicationSourceManager.html#recordLog-org.apache.hadoop.fs.Path-">recordLog</a></span>(org.apache.hadoop.fs.Path logPath)</code>
<div class="block">Check and enqueue the given log to the correct source.</div>
</td>
</tr>
-<tr id="i30" class="altColor">
+<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/ReplicationSourceManager.html#regionServerRemoved-java.lang.String-">regionServerRemoved</a></span>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> regionserver)</code>
<div class="block">A region server has been removed from the local
cluster</div>
</td>
</tr>
-<tr id="i31" class="rowColor">
+<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/ReplicationSourceManager.html#removePeer-java.lang.String-">removePeer</a></span>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> id)</code>
<div class="block">Thie method first deletes all the recovered sources for the
specified
id, then deletes the normal source (deleting all related data in ZK).</div>
</td>
</tr>
-<tr id="i32" class="altColor">
+<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/ReplicationSourceManager.html#transferQueues-java.lang.String-">transferQueues</a></span>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> rsZnode)</code>
<div class="block">Transfer all the queues of the specified to this region
server.</div>
</td>
</tr>
-<tr id="i33" class="rowColor">
+<tr id="i34" 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/ReplicationSourceManager.html#waitUntilCanBePushed-byte:A-long-java.lang.String-">waitUntilCanBePushed</a></span>(byte[] encodedName,
long seq,
@@ -550,7 +554,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>LOG</h4>
-<pre>private static final org.apache.commons.logging.Log <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.93">LOG</a></pre>
+<pre>private static final org.apache.commons.logging.Log <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.92">LOG</a></pre>
</li>
</ul>
<a name="sources">
@@ -559,7 +563,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>sources</h4>
-<pre>private final <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<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/ReplicationSourceManager.html#line.96">sources</a></pre>
+<pre>private final <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<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/ReplicationSourceManager.html#line.95">sources</a></pre>
</li>
</ul>
<a name="oldsources">
@@ -568,7 +572,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>oldsources</h4>
-<pre>private final <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<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/ReplicationSourceManager.html#line.98">oldsources</a></pre>
+<pre>private final <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<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/ReplicationSourceManager.html#line.97">oldsources</a></pre>
</li>
</ul>
<a name="replicationQueues">
@@ -577,7 +581,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>replicationQueues</h4>
-<pre>private final <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html"
title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a>
<a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.99">replicationQueues</a></pre>
+<pre>private final <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html"
title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a>
<a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.98">replicationQueues</a></pre>
</li>
</ul>
<a name="replicationTracker">
@@ -586,7 +590,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>replicationTracker</h4>
-<pre>private final <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationTracker.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationTracker</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.100">replicationTracker</a></pre>
+<pre>private final <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationTracker.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationTracker</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.99">replicationTracker</a></pre>
</li>
</ul>
<a name="replicationPeers">
@@ -595,7 +599,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>replicationPeers</h4>
-<pre>private final <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html"
title="interface in org.apache.hadoop.hbase.replication">ReplicationPeers</a>
<a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.101">replicationPeers</a></pre>
+<pre>private final <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html"
title="interface in org.apache.hadoop.hbase.replication">ReplicationPeers</a>
<a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.100">replicationPeers</a></pre>
</li>
</ul>
<a name="clusterId">
@@ -604,7 +608,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>clusterId</h4>
-<pre>private final <a
href="http://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/ReplicationSourceManager.html#line.103">clusterId</a></pre>
+<pre>private final <a
href="http://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/ReplicationSourceManager.html#line.102">clusterId</a></pre>
</li>
</ul>
<a name="server">
@@ -613,7 +617,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>server</h4>
-<pre>private final <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/ReplicationSourceManager.html#line.105">server</a></pre>
+<pre>private final <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/ReplicationSourceManager.html#line.104">server</a></pre>
</li>
</ul>
<a name="walsById">
@@ -622,7 +626,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>walsById</h4>
-<pre>private final <a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
title="class or interface in java.util">SortedSet</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>>>> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ht
ml#line.108">walsById</a></pre>
+<pre>private final <a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
title="class or interface in java.util">SortedSet</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>>>> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ht
ml#line.107">walsById</a></pre>
</li>
</ul>
<a name="walsByIdRecoveredQueues">
@@ -631,7 +635,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>walsByIdRecoveredQueues</h4>
-<pre>private final <a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
title="class or interface in java.util">SortedSet</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>>>> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ht
ml#line.110">walsByIdRecoveredQueues</a></pre>
+<pre>private final <a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
title="class or interface in java.util">SortedSet</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>>>> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ht
ml#line.109">walsByIdRecoveredQueues</a></pre>
</li>
</ul>
<a name="conf">
@@ -640,7 +644,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>conf</h4>
-<pre>private final org.apache.hadoop.conf.Configuration <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.111">conf</a></pre>
+<pre>private final org.apache.hadoop.conf.Configuration <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.110">conf</a></pre>
</li>
</ul>
<a name="fs">
@@ -649,7 +653,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>fs</h4>
-<pre>private final org.apache.hadoop.fs.FileSystem <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.112">fs</a></pre>
+<pre>private final org.apache.hadoop.fs.FileSystem <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.111">fs</a></pre>
</li>
</ul>
<a name="latestPaths">
@@ -658,7 +662,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>latestPaths</h4>
-<pre>private <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/Set.html?is-external=true";
title="class or interface in
java.util">Set</a><org.apache.hadoop.fs.Path> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.114">latestPaths</a></pre>
+<pre>private <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/Set.html?is-external=true";
title="class or interface in
java.util">Set</a><org.apache.hadoop.fs.Path> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.113">latestPaths</a></pre>
</li>
</ul>
<a name="logDir">
@@ -667,7 +671,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>logDir</h4>
-<pre>private final org.apache.hadoop.fs.Path <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.116">logDir</a></pre>
+<pre>private final org.apache.hadoop.fs.Path <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.115">logDir</a></pre>
</li>
</ul>
<a name="oldLogDir">
@@ -676,7 +680,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>oldLogDir</h4>
-<pre>private final org.apache.hadoop.fs.Path <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.118">oldLogDir</a></pre>
+<pre>private final org.apache.hadoop.fs.Path <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.117">oldLogDir</a></pre>
</li>
</ul>
<a name="walFileLengthProvider">
@@ -685,7 +689,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>walFileLengthProvider</h4>
-<pre>private final <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/ReplicationSourceManager.html#line.119">walFileLengthProvider</a></pre>
+<pre>private final <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/ReplicationSourceManager.html#line.118">walFileLengthProvider</a></pre>
</li>
</ul>
<a name="sleepBeforeFailover">
@@ -694,7 +698,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>sleepBeforeFailover</h4>
-<pre>private final long <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.121">sleepBeforeFailover</a></pre>
+<pre>private final long <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.120">sleepBeforeFailover</a></pre>
</li>
</ul>
<a name="executor">
@@ -703,7 +707,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>executor</h4>
-<pre>private final <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ThreadPoolExecutor.html?is-external=true";
title="class or interface in java.util.concurrent">ThreadPoolExecutor</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.123">executor</a></pre>
+<pre>private final <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ThreadPoolExecutor.html?is-external=true";
title="class or interface in java.util.concurrent">ThreadPoolExecutor</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.122">executor</a></pre>
</li>
</ul>
<a name="replicationForBulkLoadDataEnabled">
@@ -712,7 +716,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>replicationForBulkLoadDataEnabled</h4>
-<pre>private final boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.125">replicationForBulkLoadDataEnabled</a></pre>
+<pre>private final boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.124">replicationForBulkLoadDataEnabled</a></pre>
</li>
</ul>
<a name="connection">
@@ -721,7 +725,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>connection</h4>
-<pre>private <a
href="../../../../../../org/apache/hadoop/hbase/client/Connection.html"
title="interface in org.apache.hadoop.hbase.client">Connection</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.127">connection</a></pre>
+<pre>private <a
href="../../../../../../org/apache/hadoop/hbase/client/Connection.html"
title="interface in org.apache.hadoop.hbase.client">Connection</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.126">connection</a></pre>
</li>
</ul>
<a name="replicationWaitTime">
@@ -730,7 +734,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>replicationWaitTime</h4>
-<pre>private long <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.128">replicationWaitTime</a></pre>
+<pre>private long <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.127">replicationWaitTime</a></pre>
</li>
</ul>
<a name="totalBufferUsed">
@@ -739,7 +743,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockListLast">
<li class="blockList">
<h4>totalBufferUsed</h4>
-<pre>private <a
href="http://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/ReplicationSourceManager.html#line.130">totalBufferUsed</a></pre>
+<pre>private <a
href="http://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/ReplicationSourceManager.html#line.129">totalBufferUsed</a></pre>
</li>
</ul>
</li>
@@ -756,7 +760,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockListLast">
<li class="blockList">
<h4>ReplicationSourceManager</h4>
-<pre>public <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.144">ReplicationSourceManager</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationQueues</a> replicationQueues,
+<pre>public <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.143">ReplicationSourceManager</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationQueues</a> replicationQueues,
<a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationPeers</a> replicationPeers,
<a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationTracker.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationTracker</a> replicationTracker,
org.apache.hadoop.conf.Configuration conf,
@@ -798,7 +802,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>logPositionAndCleanOldLogs</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.199">logPositionAndCleanOldLogs</a>(org.apache.hadoop.fs.Path log,
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.198">logPositionAndCleanOldLogs</a>(org.apache.hadoop.fs.Path log,
<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> id,
long position,
boolean queueRecovered,
@@ -823,7 +827,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>cleanOldLogs</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.216">cleanOldLogs</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> key,
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.215">cleanOldLogs</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> key,
<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> id,
boolean queueRecovered)</pre>
<div class="block">Cleans a log file and all older files from ZK. Called when
we are sure that a
@@ -842,7 +846,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>cleanOldLogs</h4>
-<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.233">cleanOldLogs</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
title="class or interface in java.util">SortedSet</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>> wals,
+<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.232">cleanOldLogs</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
title="class or interface in java.util">SortedSet</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>> wals,
<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> key,
<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> id)</pre>
</li>
@@ -853,7 +857,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>init</h4>
-<pre>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.246">init</a>()
+<pre>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.245">init</a>()
throws <a
href="http://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="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html"
title="class in
org.apache.hadoop.hbase.replication">ReplicationException</a></pre>
<div class="block">Adds a normal source per registered peer cluster and tries
to process all
@@ -871,7 +875,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>addSource</h4>
-<pre><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/ReplicationSourceManager.html#line.271">addSource</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> id)
+<pre><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/ReplicationSourceManager.html#line.270">addSource</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> id)
throws <a
href="http://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="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html"
title="class in
org.apache.hadoop.hbase.replication">ReplicationException</a></pre>
<div class="block">Add sources for the given peer cluster on this region
server. For the newly added peer, we only
@@ -887,13 +891,22 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
</dl>
</li>
</ul>
+<a name="getSizeOfLatestPath--">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>getSizeOfLatestPath</h4>
+<pre>int <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.308">getSizeOfLatestPath</a>()</pre>
+</li>
+</ul>
<a name="deleteSource-java.lang.String-boolean-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>deleteSource</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.312">deleteSource</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> peerId,
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.318">deleteSource</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> peerId,
boolean closeConnection)</pre>
<div class="block">Delete a complete queue of wals associated with a peer
cluster</div>
<dl>
@@ -908,7 +921,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>join</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.322">join</a>()</pre>
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.328">join</a>()</pre>
<div class="block">Terminate the replication on this region server</div>
</li>
</ul>
@@ -918,7 +931,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>getWALs</h4>
-<pre><a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
title="class or interface in java.util">SortedSet</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>>>> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.334">g
etWALs</a>()</pre>
+<pre><a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
title="class or interface in java.util">SortedSet</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>>>> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.340">g
etWALs</a>()</pre>
<div class="block">Get a copy of the wals of the first source on this rs</div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
@@ -932,7 +945,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>getWalsByIdRecoveredQueues</h4>
-<pre><a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
title="class or interface in java.util">SortedSet</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>>>> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.343">g
etWalsByIdRecoveredQueues</a>()</pre>
+<pre><a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>,<a
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
title="class or interface in java.util">SortedSet</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>>>> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.349">g
etWalsByIdRecoveredQueues</a>()</pre>
<div class="block">Get a copy of the wals of the recovered sources on this
rs</div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
@@ -946,7 +959,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>getSources</h4>
-<pre>public <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<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/ReplicationSourceManager.html#line.351">getSources</a>()</pre>
+<pre>public <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<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/ReplicationSourceManager.html#line.357">getSources</a>()</pre>
<div class="block">Get a list of all the normal sources of this rs</div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
@@ -960,7 +973,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>getOldSources</h4>
-<pre>public <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<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/ReplicationSourceManager.html#line.359">getOldSources</a>()</pre>
+<pre>public <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<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/ReplicationSourceManager.html#line.365">getOldSources</a>()</pre>
<div class="block">Get a list of all the old sources of this rs</div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
@@ -974,7 +987,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>getSource</h4>
-<pre>public <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/ReplicationSourceManager.html#line.368">getSource</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> peerId)</pre>
+<pre>public <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/ReplicationSourceManager.html#line.374">getSource</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> peerId)</pre>
<div class="block">Get the normal source for a given peer</div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
@@ -990,7 +1003,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>getAllQueues</h4>
-<pre><a
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.373">getAllQueues</a>()</pre>
+<pre><a
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.379">getAllQueues</a>()</pre>
</li>
</ul>
<a name="preLogRoll-org.apache.hadoop.fs.Path-">
@@ -999,7 +1012,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>preLogRoll</h4>
-<pre>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.377">preLogRoll</a>(org.apache.hadoop.fs.Path newLog)
+<pre>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.383">preLogRoll</a>(org.apache.hadoop.fs.Path newLog)
throws <a
href="http://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>
@@ -1013,7 +1026,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>recordLog</h4>
-<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.400">recordLog</a>(org.apache.hadoop.fs.Path logPath)
+<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.406">recordLog</a>(org.apache.hadoop.fs.Path logPath)
throws <a
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
title="class or interface in java.io">IOException</a></pre>
<div class="block">Check and enqueue the given log to the correct source. If
there's still no source for the
group to which the given log belongs, create one</div>
@@ -1031,7 +1044,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>postLogRoll</h4>
-<pre>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.444">postLogRoll</a>(org.apache.hadoop.fs.Path newLog)
+<pre>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.450">postLogRoll</a>(org.apache.hadoop.fs.Path newLog)
throws <a
href="http://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>
@@ -1045,7 +1058,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>getTotalBufferUsed</h4>
-<pre>public <a
href="http://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/ReplicationSourceManager.html#line.452">getTotalBufferUsed</a>()</pre>
+<pre>public <a
href="http://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/ReplicationSourceManager.html#line.458">getTotalBufferUsed</a>()</pre>
</li>
</ul>
<a
name="getReplicationSource-org.apache.hadoop.conf.Configuration-org.apache.hadoop.fs.FileSystem-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager-org.apache.hadoop.hbase.replication.ReplicationQueues-org.apache.hadoop.hbase.replication.ReplicationPeers-org.apache.hadoop.hbase.Server-java.lang.String-java.util.UUID-org.apache.hadoop.hbase.replication.ReplicationPeerConfig-org.apache.hadoop.hbase.replication.ReplicationPeer-org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider-">
@@ -1054,7 +1067,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>getReplicationSource</h4>
-<pre>private <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/ReplicationSourceManager.html#line.466">getReplicationSource</a>(org.apache.hadoop.conf.Configuration conf,
+<pre>private <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/ReplicationSourceManager.html#line.472">getReplicationSource</a>(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a> manager,
<a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationQueues</a> replicationQueues,
@@ -1087,7 +1100,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>transferQueues</h4>
-<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.524">transferQueues</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> rsZnode)</pre>
+<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.530">transferQueues</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> rsZnode)</pre>
<div class="block">Transfer all the queues of the specified to this region
server.
First it tries to grab a lock and if it works it will move the
znodes and finally will delete the old znodes.
@@ -1105,7 +1118,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>closeRecoveredQueue</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.539">closeRecoveredQueue</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a> src)</pre>
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.545">closeRecoveredQueue</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a> src)</pre>
<div class="block">Clear the references to the specified old source</div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
@@ -1119,7 +1132,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>closeQueue</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.553">closeQueue</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a> src)</pre>
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.559">closeQueue</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a> src)</pre>
<div class="block">Clear the references to the specified old source</div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
@@ -1133,7 +1146,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>removePeer</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.566">removePeer</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> id)</pre>
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.572">removePeer</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> id)</pre>
<div class="block">Thie method first deletes all the recovered sources for the
specified
id, then deletes the normal source (deleting all related data in ZK).</div>
<dl>
@@ -1148,7 +1161,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>regionServerRemoved</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.611">regionServerRemoved</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> regionserver)</pre>
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.617">regionServerRemoved</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> regionserver)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from
interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationListener.html#regionServerRemoved-java.lang.String-">ReplicationListener</a></code></span></div>
<div class="block">A region server has been removed from the local
cluster</div>
<dl>
@@ -1165,7 +1178,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>peerRemoved</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.616">peerRemoved</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> peerId)</pre>
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.622">peerRemoved</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> peerId)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from
interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationListener.html#peerRemoved-java.lang.String-">ReplicationListener</a></code></span></div>
<div class="block">A peer cluster has been removed (i.e. unregistered) from
replication.</div>
<dl>
@@ -1182,7 +1195,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>peerListChanged</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.622">peerListChanged</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>> peerIds)</pre>
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.628">peerListChanged</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>> peerIds)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from
interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationListener.html#peerListChanged-java.util.List-">ReplicationListener</a></code></span></div>
<div class="block">The list of registered peer clusters has changed.</div>
<dl>
@@ -1199,7 +1212,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>getOldLogDir</h4>
-<pre>public org.apache.hadoop.fs.Path <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.798">getOldLogDir</a>()</pre>
+<pre>public org.apache.hadoop.fs.Path <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.804">getOldLogDir</a>()</pre>
<div class="block">Get the directory where wals are archived</div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
@@ -1213,7 +1226,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>getLogDir</h4>
-<pre>public org.apache.hadoop.fs.Path <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.806">getLogDir</a>()</pre>
+<pre>public org.apache.hadoop.fs.Path <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.812">getLogDir</a>()</pre>
<div class="block">Get the directory where wals are stored by their RSs</div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
@@ -1227,7 +1240,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>getFs</h4>
-<pre>public org.apache.hadoop.fs.FileSystem <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.814">getFs</a>()</pre>
+<pre>public org.apache.hadoop.fs.FileSystem <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.820">getFs</a>()</pre>
<div class="block">Get the handle on the local file system</div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
@@ -1241,7 +1254,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>getConnection</h4>
-<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/client/Connection.html"
title="interface in org.apache.hadoop.hbase.client">Connection</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.818">getConnection</a>()</pre>
+<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/client/Connection.html"
title="interface in org.apache.hadoop.hbase.client">Connection</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.824">getConnection</a>()</pre>
</li>
</ul>
<a name="getReplicationPeers--">
@@ -1250,7 +1263,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>getReplicationPeers</h4>
-<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationPeers</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.826">getReplicationPeers</a>()</pre>
+<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationPeers</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.832">getReplicationPeers</a>()</pre>
<div class="block">Get the ReplicationPeers used by this
ReplicationSourceManager</div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
@@ -1264,7 +1277,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>getStats</h4>
-<pre>public <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.831">getStats</a>()</pre>
+<pre>public <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.837">getStats</a>()</pre>
<div class="block">Get a string representation of all the sources'
metrics</div>
</li>
</ul>
@@ -1274,7 +1287,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>addHFileRefs</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.844">addHFileRefs</a>(<a
href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class
in org.apache.hadoop.hbase">TableName</a> tableName,
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.850">addHFileRefs</a>(<a
href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class
in org.apache.hadoop.hbase">TableName</a> tableName,
byte[] family,
<a
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<a
href="../../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in
org.apache.hadoop.hbase.util">Pair</a><org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> pairs)
throws <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html"
title="class in
org.apache.hadoop.hbase.replication">ReplicationException</a></pre>
@@ -1290,7 +1303,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>cleanUpHFileRefs</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.851">cleanUpHFileRefs</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> peerId,
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.857">cleanUpHFileRefs</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> peerId,
<a
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a>> files)</pre>
</li>
</ul>
@@ -1300,7 +1313,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockListLast">
<li class="blockList">
<h4>waitUntilCanBePushed</h4>
-<pre>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.865">waitUntilCanBePushed</a>(byte[] encodedName,
+<pre>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.871">waitUntilCanBePushed</a>(byte[] encodedName,
long seq,
<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
title="class or interface in java.lang">String</a> peerId)
throws <a
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
title="class or interface in java.io">IOException</a>,
