http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1f2eeb22/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 fef1692..852f85c 100644
---
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html
+++
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html
@@ -18,8 +18,8 @@
catch(err) {
}
//-->
-var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"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,"i36":10,"i37":10,"i38":10};
-var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],8:["t4","Concrete Methods"]};
+var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":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,"i36":10,"i37":9,"i38":10,"i39":10,"i40":10};
+var tabs = {65535:["t0","All Methods"],1:["t1","Static
Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
var tableTab = "tableTab";
@@ -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.114">ReplicationSourceManager</a>
+public class <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.123">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
sources. There are two classes of
@@ -135,14 +135,15 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
operations.</li>
<li>Need synchronized on <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#walsById"><code>walsById</code></a>.
There are four methods which modify it,
<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#addPeer-java.lang.String-"><code>addPeer(String)</code></a>,
<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#removePeer-java.lang.String-"><code>removePeer(String)</code></a>,
- <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#cleanOldLogs-java.util.SortedSet-java.lang.String-java.lang.String-"><code>cleanOldLogs(SortedSet,
String, String)</code></a> and <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#preLogRoll-org.apache.hadoop.fs.Path-"><code>preLogRoll(Path)</code></a>.
<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#walsById"><code>walsById</code></a>
- is a ConcurrentHashMap and there is a Lock for peer id in <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/PeerProcedureHandlerImpl.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver"><code>PeerProcedureHandlerImpl</code></a>.
So
- there is no race between <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#addPeer-java.lang.String-"><code>addPeer(String)</code></a>
and <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#removePeer-java.lang.String-"><code>removePeer(String)</code></a>.
- <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#cleanOldLogs-java.util.SortedSet-java.lang.String-java.lang.String-"><code>cleanOldLogs(SortedSet,
String, String)</code></a> is called by <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver"><code>ReplicationSourceInterface</code></a>.
- So no race with <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#addPeer-java.lang.String-"><code>addPeer(String)</code></a>.
<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#removePeer-java.lang.String-"><code>removePeer(String)</code></a>
will terminate the
- <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver"><code>ReplicationSourceInterface</code></a>
firstly, then remove the wals from <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#walsById"><code>walsById</code></a>.
So no
- race with <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#removePeer-java.lang.String-"><code>removePeer(String)</code></a>.
The only case need synchronized is
- <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#cleanOldLogs-java.util.SortedSet-java.lang.String-java.lang.String-"><code>cleanOldLogs(SortedSet,
String, String)</code></a> and <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#preLogRoll-org.apache.hadoop.fs.Path-"><code>preLogRoll(Path)</code></a>.</li>
+ <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#cleanOldLogs-java.util.SortedSet-java.lang.String-java.lang.String-"><code>cleanOldLogs(SortedSet,
String, String)</code></a> and <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#preLogRoll-org.apache.hadoop.fs.Path-"><code>preLogRoll(Path)</code></a>.
+ <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#walsById"><code>walsById</code></a>
is a ConcurrentHashMap and there is a Lock for peer id in
+ <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/PeerProcedureHandlerImpl.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver"><code>PeerProcedureHandlerImpl</code></a>.
So there is no race between <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#addPeer-java.lang.String-"><code>addPeer(String)</code></a>
and
+ <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#removePeer-java.lang.String-"><code>removePeer(String)</code></a>.
<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#cleanOldLogs-java.util.SortedSet-java.lang.String-java.lang.String-"><code>cleanOldLogs(SortedSet,
String, String)</code></a> is called by
+ <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver"><code>ReplicationSourceInterface</code></a>.
So no race with <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#addPeer-java.lang.String-"><code>addPeer(String)</code></a>.
+ <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#removePeer-java.lang.String-"><code>removePeer(String)</code></a>
will terminate the <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver"><code>ReplicationSourceInterface</code></a>
firstly, then
+ remove the wals from <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#walsById"><code>walsById</code></a>.
So no race with <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#removePeer-java.lang.String-"><code>removePeer(String)</code></a>.
The only
+ case need synchronized is <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#cleanOldLogs-java.util.SortedSet-java.lang.String-java.lang.String-"><code>cleanOldLogs(SortedSet,
String, String)</code></a> and
+ <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#preLogRoll-org.apache.hadoop.fs.Path-"><code>preLogRoll(Path)</code></a>.</li>
<li>No need synchronized on <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#walsByIdRecoveredQueues"><code>walsByIdRecoveredQueues</code></a>.
There are three methods which
modify it, <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#removePeer-java.lang.String-"><code>removePeer(String)</code></a>
, <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#cleanOldLogs-java.util.SortedSet-java.lang.String-java.lang.String-"><code>cleanOldLogs(SortedSet,
String, String)</code></a> and
<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.NodeFailoverWorker.html#run--"><code>ReplicationSourceManager.NodeFailoverWorker.run()</code></a>.
@@ -328,7 +329,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
</a>
<h3>Method Summary</h3>
<table class="memberSummary" border="0" cellpadding="3" cellspacing="0"
summary="Method Summary table, listing methods, and an explanation">
-<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span
class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a
href="javascript:show(2);">Instance Methods</a></span><span
class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a
href="javascript:show(8);">Concrete Methods</a></span><span
class="tabEnd"> </span></span></caption>
+<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span
class="tabEnd"> </span></span><span id="t1" class="tableTab"><span><a
href="javascript:show(1);">Static Methods</a></span><span
class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a
href="javascript:show(2);">Instance Methods</a></span><span
class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a
href="javascript:show(8);">Concrete Methods</a></span><span
class="tabEnd"> </span></span></caption>
<tr>
<th class="colFirst" scope="col">Modifier and Type</th>
<th class="colLast" scope="col">Method and Description</th>
@@ -498,11 +499,11 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
</td>
</tr>
<tr id="i29" class="rowColor">
-<td class="colFirst"><code>(package private) void</code></td>
+<td class="colFirst"><code>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="i30" class="altColor">
-<td class="colFirst"><code>(package private) void</code></td>
+<td class="colFirst"><code>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="i31" class="rowColor">
@@ -537,16 +538,29 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
</td>
</tr>
<tr id="i36" 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#scopeWALEdits-org.apache.hadoop.hbase.wal.WALKey-org.apache.hadoop.hbase.wal.WALEdit-">scopeWALEdits</a></span>(<a
href="../../../../../../org/apache/hadoop/hbase/wal/WALKey.html"
title="interface in org.apache.hadoop.hbase.wal">WALKey</a> logKey,
+ <a
href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class
in org.apache.hadoop.hbase.wal">WALEdit</a> logEdit)</code> </td>
+</tr>
+<tr id="i37" class="rowColor">
+<td class="colFirst"><code>(package private) static void</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#scopeWALEdits-org.apache.hadoop.hbase.wal.WALKey-org.apache.hadoop.hbase.wal.WALEdit-org.apache.hadoop.conf.Configuration-">scopeWALEdits</a></span>(<a
href="../../../../../../org/apache/hadoop/hbase/wal/WALKey.html"
title="interface in org.apache.hadoop.hbase.wal">WALKey</a> logKey,
+ <a
href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class
in org.apache.hadoop.hbase.wal">WALEdit</a> logEdit,
+ org.apache.hadoop.conf.Configuration conf)</code>
+<div class="block">Utility method used to set the correct scopes on each log
key.</div>
+</td>
+</tr>
+<tr id="i38" 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#throwIOExceptionWhenFail-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager.ReplicationQueueOperation-">throwIOExceptionWhenFail</a></span>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ReplicationQueueOperation.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager.ReplicationQueueOperation</a> op)</code> </td>
</tr>
-<tr id="i37" class="rowColor">
+<tr id="i39" 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-org.apache.hadoop.hbase.ServerName-">transferQueues</a></span>(<a
href="../../../../../../org/apache/hadoop/hbase/ServerName.html" title="class
in org.apache.hadoop.hbase">ServerName</a> deadRS)</code>
<div class="block">Transfer all the queues of the specified to this region
server.</div>
</td>
</tr>
-<tr id="i38" class="altColor">
+<tr id="i40" 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,
@@ -582,7 +596,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>LOG</h4>
-<pre>private static final org.slf4j.Logger <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.115">LOG</a></pre>
+<pre>private static final org.slf4j.Logger <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.124">LOG</a></pre>
</li>
</ul>
<a name="sources">
@@ -591,7 +605,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/concurrent/ConcurrentMap.html?is-external=true"
title="class or interface in java.util.concurrent">ConcurrentMap</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="../../../../../../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.117">sources</a></pre>
+<pre>private final <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true"
title="class or interface in java.util.concurrent">ConcurrentMap</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="../../../../../../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.126">sources</a></pre>
</li>
</ul>
<a name="oldsources">
@@ -600,7 +614,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.119">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.128">oldsources</a></pre>
</li>
</ul>
<a name="queueStorage">
@@ -609,7 +623,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>queueStorage</h4>
-<pre>private final <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/ReplicationSourceManager.html#line.120">queueStorage</a></pre>
+<pre>private final <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/ReplicationSourceManager.html#line.129">queueStorage</a></pre>
</li>
</ul>
<a name="replicationTracker">
@@ -618,7 +632,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.121">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.130">replicationTracker</a></pre>
</li>
</ul>
<a name="replicationPeers">
@@ -627,7 +641,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="class in org.apache.hadoop.hbase.replication">ReplicationPeers</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.122">replicationPeers</a></pre>
+<pre>private final <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html"
title="class in org.apache.hadoop.hbase.replication">ReplicationPeers</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.131">replicationPeers</a></pre>
</li>
</ul>
<a name="clusterId">
@@ -636,7 +650,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.124">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.133">clusterId</a></pre>
</li>
</ul>
<a name="server">
@@ -645,7 +659,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.126">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.135">server</a></pre>
</li>
</ul>
<a name="walsById">
@@ -654,7 +668,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/concurrent/ConcurrentMap.html?is-external=true"
title="class or interface in java.util.concurrent">ConcurrentMap</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/replicatio
n/regionserver/ReplicationSourceManager.html#line.131">walsById</a></pre>
+<pre>private final <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true"
title="class or interface in java.util.concurrent">ConcurrentMap</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/replicatio
n/regionserver/ReplicationSourceManager.html#line.140">walsById</a></pre>
</li>
</ul>
<a name="walsByIdRecoveredQueues">
@@ -663,7 +677,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/concurrent/ConcurrentMap.html?is-external=true"
title="class or interface in java.util.concurrent">ConcurrentMap</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/replicatio
n/regionserver/ReplicationSourceManager.html#line.135">walsByIdRecoveredQueues</a></pre>
+<pre>private final <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true"
title="class or interface in java.util.concurrent">ConcurrentMap</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/replicatio
n/regionserver/ReplicationSourceManager.html#line.144">walsByIdRecoveredQueues</a></pre>
</li>
</ul>
<a name="conf">
@@ -672,7 +686,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.137">conf</a></pre>
+<pre>private final org.apache.hadoop.conf.Configuration <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.146">conf</a></pre>
</li>
</ul>
<a name="fs">
@@ -681,7 +695,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.138">fs</a></pre>
+<pre>private final org.apache.hadoop.fs.FileSystem <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.147">fs</a></pre>
</li>
</ul>
<a name="latestPaths">
@@ -690,7 +704,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>latestPaths</h4>
-<pre>private final <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.140">latestPaths</a></pre>
+<pre>private final <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.149">latestPaths</a></pre>
</li>
</ul>
<a name="logDir">
@@ -699,7 +713,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.142">logDir</a></pre>
+<pre>private final org.apache.hadoop.fs.Path <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.151">logDir</a></pre>
</li>
</ul>
<a name="oldLogDir">
@@ -708,7 +722,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.144">oldLogDir</a></pre>
+<pre>private final org.apache.hadoop.fs.Path <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.153">oldLogDir</a></pre>
</li>
</ul>
<a name="walFileLengthProvider">
@@ -717,7 +731,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.145">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.154">walFileLengthProvider</a></pre>
</li>
</ul>
<a name="sleepBeforeFailover">
@@ -726,7 +740,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.147">sleepBeforeFailover</a></pre>
+<pre>private final long <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.156">sleepBeforeFailover</a></pre>
</li>
</ul>
<a name="executor">
@@ -735,7 +749,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.149">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.158">executor</a></pre>
</li>
</ul>
<a name="replicationForBulkLoadDataEnabled">
@@ -744,7 +758,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.151">replicationForBulkLoadDataEnabled</a></pre>
+<pre>private final boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.160">replicationForBulkLoadDataEnabled</a></pre>
</li>
</ul>
<a name="connection">
@@ -753,7 +767,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.153">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.162">connection</a></pre>
</li>
</ul>
<a name="replicationWaitTime">
@@ -762,7 +776,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.154">replicationWaitTime</a></pre>
+<pre>private long <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.163">replicationWaitTime</a></pre>
</li>
</ul>
<a name="totalBufferUsed">
@@ -771,7 +785,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.156">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.165">totalBufferUsed</a></pre>
</li>
</ul>
</li>
@@ -788,7 +802,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.170">ReplicationSourceManager</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueStorage.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationQueueStorage</a> queueStorage,
+<pre>public <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.179">ReplicationSourceManager</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueStorage.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationQueueStorage</a> queueStorage,
<a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html"
title="class 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,
@@ -830,7 +844,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>init</h4>
-<pre><a
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Future.html?is-external=true"
title="class or interface in java.util.concurrent">Future</a><?> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.218">init</a>()
+<pre><a
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Future.html?is-external=true"
title="class or interface in java.util.concurrent">Future</a><?> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.227">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></pre>
<div class="block">Adds a normal source per registered peer cluster and tries
to process all old region server wal
queues
@@ -848,7 +862,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>adoptAbandonedQueues</h4>
-<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.230">adoptAbandonedQueues</a>()</pre>
+<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.239">adoptAbandonedQueues</a>()</pre>
</li>
</ul>
<a name="addPeer-java.lang.String-">
@@ -857,7 +871,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>addPeer</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.259">addPeer</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.268">addPeer</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)
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">1. Add peer to replicationPeers 2. Add the normal source
and related replication queue 3. Add
HFile Refs</div>
@@ -875,7 +889,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.280">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> peerId)</pre>
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.289">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> peerId)</pre>
<div class="block">1. Remove peer for replicationPeers 2. Remove all the
recovered sources for the specified id
and related replication queues 3. Remove the normal source and related
replication queue 4.
Remove HFile Refs</div>
@@ -891,7 +905,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>createSource</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.322">createSource</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> queueId,
+<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.331">createSource</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> queueId,
<a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeer.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationPeer</a> replicationPeer)
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">Factory method to create a replication source</div>
@@ -911,7 +925,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.341">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> peerId)
+<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.350">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> 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></pre>
<div class="block">Add a normal source for the given peer on this region
server. Meanwhile, add new replication
queue to storage. For the newly added peer, we only need to enqueue the
latest log of each wal
@@ -932,7 +946,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>refreshSources</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.375">refreshSources</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.384">refreshSources</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)
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">Close the previous replication sources of this peer id and
open new sources to trigger the new
replication state changes or new replication config changes. Here we don't
need to change
@@ -951,7 +965,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>removeRecoveredSource</h4>
-<pre>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.423">removeRecoveredSource</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>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.432">removeRecoveredSource</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 metrics and related replication queue of the
specified old source</div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
@@ -965,7 +979,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>removeSource</h4>
-<pre>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.436">removeSource</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>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.445">removeSource</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 metrics and related replication queue of the
specified old source</div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
@@ -979,7 +993,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>deleteQueue</h4>
-<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.449">deleteQueue</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> queueId)</pre>
+<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.458">deleteQueue</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> queueId)</pre>
<div class="block">Delete a complete queue of wals associated with a
replication source</div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
@@ -993,7 +1007,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>abortWhenFail</h4>
-<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.458">abortWhenFail</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ReplicationQueueOperation.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager.ReplicationQueueOperation</a> op)</pre>
+<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.467">abortWhenFail</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ReplicationQueueOperation.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager.ReplicationQueueOperation</a> op)</pre>
</li>
</ul>
<a
name="throwIOExceptionWhenFail-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager.ReplicationQueueOperation-">
@@ -1002,7 +1016,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>throwIOExceptionWhenFail</h4>
-<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.466">throwIOExceptionWhenFail</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ReplicationQueueOperation.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager.ReplicationQueueOperation</a> op)
+<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.475">throwIOExceptionWhenFail</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ReplicationQueueOperation.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager.ReplicationQueueOperation</a> op)
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>
@@ -1016,7 +1030,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>abortAndThrowIOExceptionWhenFail</h4>
-<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.474">abortAndThrowIOExceptionWhenFail</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ReplicationQueueOperation.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager.ReplicationQueueOperation</a> op)
+<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.483">abortAndThrowIOExceptionWhenFail</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ReplicationQueueOperation.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager.ReplicationQueueOperation</a> op)
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>
@@ -1030,7 +1044,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.491">logPositionAndCleanOldLogs</a>(org.apache.hadoop.fs.Path log,
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.500">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> queueId,
long position,
boolean queueRecovered)</pre>
@@ -1051,7 +1065,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>cleanOldLogs</h4>
-<pre>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.507">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> log,
+<pre>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.516">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> 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> queueId,
boolean queueRecovered)</pre>
<div class="block">Cleans a log file and all older logs from replication
queue. Called when we are sure that a log
@@ -1070,7 +1084,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.525">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.534">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>
@@ -1081,8 +1095,8 @@ 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.536">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>
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.547">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>
<dd><code><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></code></dd>
@@ -1095,21 +1109,57 @@ 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.591">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>
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.604">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>
<dd><code><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></code></dd>
</dl>
</li>
</ul>
+<a
name="scopeWALEdits-org.apache.hadoop.hbase.wal.WALKey-org.apache.hadoop.hbase.wal.WALEdit-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>scopeWALEdits</h4>
+<pre>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.611">scopeWALEdits</a>(<a
href="../../../../../../org/apache/hadoop/hbase/wal/WALKey.html"
title="interface in org.apache.hadoop.hbase.wal">WALKey</a> logKey,
+ <a
href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class
in org.apache.hadoop.hbase.wal">WALEdit</a> logEdit)
+ 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>
+<dd><code><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></code></dd>
+</dl>
+</li>
+</ul>
+<a
name="scopeWALEdits-org.apache.hadoop.hbase.wal.WALKey-org.apache.hadoop.hbase.wal.WALEdit-org.apache.hadoop.conf.Configuration-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>scopeWALEdits</h4>
+<pre>static void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.623">scopeWALEdits</a>(<a
href="../../../../../../org/apache/hadoop/hbase/wal/WALKey.html"
title="interface in org.apache.hadoop.hbase.wal">WALKey</a> logKey,
+ <a
href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class
in org.apache.hadoop.hbase.wal">WALEdit</a> logEdit,
+ org.apache.hadoop.conf.Configuration conf)
+ 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">Utility method used to set the correct scopes on each log
key. Doesn't set a scope on keys from
+ compaction WAL edits and if the scope is local.</div>
+<dl>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>logKey</code> - Key that may get scoped according to its edits</dd>
+<dd><code>logEdit</code> - Edits used to lookup the scopes</dd>
+<dt><span class="throwsLabel">Throws:</span></dt>
+<dd><code><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></code> - If failed to
parse the WALEdit</dd>
+</dl>
+</li>
+</ul>
<a name="regionServerRemoved-java.lang.String-">
<!-- -->
</a>
<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.599">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.649">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>
@@ -1126,7 +1176,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.609">transferQueues</a>(<a
href="../../../../../../org/apache/hadoop/hbase/ServerName.html" title="class
in org.apache.hadoop.hbase">ServerName</a> deadRS)</pre>
+<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.659">transferQueues</a>(<a
href="../../../../../../org/apache/hadoop/hbase/ServerName.html" title="class
in org.apache.hadoop.hbase">ServerName</a> deadRS)</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 old queues and finally will delete the old
queues.
<p>
@@ -1139,7 +1189,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.738">join</a>()</pre>
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.788">join</a>()</pre>
<div class="block">Terminate the replication on this region server</div>
</li>
</ul>
@@ -1149,7 +1199,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.750">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.800">g
etWALs</a>()</pre>
<div class="block">Get a copy of the wals of the normal sources on this
rs</div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
@@ -1163,7 +1213,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.759">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.809">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>
@@ -1177,7 +1227,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.767">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.817">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>
@@ -1191,7 +1241,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.775">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.825">getOldSources</a>()</pre>
<div class="block">Get a list of all the recovered sources of this rs</div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
@@ -1205,7 +1255,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.784">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.834">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="returnLabel">Returns:</span></dt>
@@ -1219,7 +1269,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.789">getAllQueues</a>()
+<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.839">getAllQueues</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></pre>
<dl>
<dt><span class="throwsLabel">Throws:</span></dt>
@@ -1233,7 +1283,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>getSizeOfLatestPath</h4>
-<pre>int <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.800">getSizeOfLatestPath</a>()</pre>
+<pre>int <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.850">getSizeOfLatestPath</a>()</pre>
</li>
</ul>
<a name="getTotalBufferUsed--">
@@ -1242,7 +1292,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.807">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.857">getTotalBufferUsed</a>()</pre>
</li>
</ul>
<a name="getOldLogDir--">
@@ -1251,7 +1301,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.815">getOldLogDir</a>()</pre>
+<pre>public org.apache.hadoop.fs.Path <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.865">getOldLogDir</a>()</pre>
<div class="block">Get the directory where wals are archived</div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
@@ -1265,7 +1315,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.823">getLogDir</a>()</pre>
+<pre>public org.apache.hadoop.fs.Path <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.873">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>
@@ -1279,7 +1329,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.831">getFs</a>()</pre>
+<pre>public org.apache.hadoop.fs.FileSystem <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.881">getFs</a>()</pre>
<div class="block">Get the handle on the local file system</div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
@@ -1293,7 +1343,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.835">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.885">getConnection</a>()</pre>
</li>
</ul>
<a name="getReplicationPeers--">
@@ -1302,7 +1352,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="class in
org.apache.hadoop.hbase.replication">ReplicationPeers</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.843">getReplicationPeers</a>()</pre>
+<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html"
title="class in
org.apache.hadoop.hbase.replication">ReplicationPeers</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.893">getReplicationPeers</a>()</pre>
<div class="block">Get the ReplicationPeers used by this
ReplicationSourceManager</div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
@@ -1316,7 +1366,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.850">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.900">getStats</a>()</pre>
<div class="block">Get a string representation of all the sources'
metrics</div>
</li>
</ul>
@@ -1326,7 +1376,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.863">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.913">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="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>
@@ -1342,7 +1392,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.870">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.920">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>
@@ -1352,7 +1402,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
<ul class="blockList">
<li class="blockList">
<h4>activeFailoverTaskCount</h4>
-<pre>int <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.874">activeFailoverTaskCount</a>()</pre>
+<pre>int <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.924">activeFailoverTaskCount</a>()</pre>
</li>
</ul>
<a name="waitUntilCanBePushed-byte:A-long-java.lang.String-">
@@ -1361,7 +1411,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.887">waitUntilCanBePushed</a>(byte[] encodedName,
+<pre>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.937">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>,