You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by mi...@apache.org on 2015/12/10 18:12:39 UTC
[17/51] [partial] hbase-site git commit: Published site at
26ac60b03f80c9215103a02db783341e67037753.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f68717a0/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html
----------------------------------------------------------------------
diff --git a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html
index f46b79b..366939e 100644
--- a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html
+++ b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html
@@ -105,7 +105,7 @@
<hr>
<br>
<pre><a href="../../../../../../org/apache/hadoop/hbase/classification/InterfaceAudience.Private.html" title="annotation in org.apache.hadoop.hbase.classification">@InterfaceAudience.Private</a>
-public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.82">ReplicationSource</a>
+public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.86">ReplicationSource</a>
extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?is-external=true" title="class or interface in java.lang">Thread</a>
implements <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html" title="interface in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a></pre>
<div class="block">Class that handles the source of a replication stream.
@@ -319,47 +319,55 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<th class="colLast" scope="col">Method and Description</th>
</tr>
<tr class="altColor">
+<td class="colFirst"><code>void</code></td>
+<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#addHFileRefs(org.apache.hadoop.hbase.TableName,%20byte[],%20java.util.List)">addHFileRefs</a></strong>(<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/7/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/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>> files)</code>
+<div class="block">Add hfile names to the queue to be replicated.</div>
+</td>
+</tr>
+<tr class="rowColor">
<td class="colFirst"><code>private void</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#decorateConf()">decorateConf</a></strong>()</code> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#enqueueLog(org.apache.hadoop.fs.Path)">enqueueLog</a></strong>(org.apache.hadoop.fs.Path log)</code>
<div class="block">Add a log to the list of logs to replicate</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code>org.apache.hadoop.fs.Path</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getCurrentPath()">getCurrentPath</a></strong>()</code>
<div class="block">Get the current log that's replicated</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getPeerClusterId()">getPeerClusterId</a></strong>()</code>
<div class="block">Get the id that the source is replicating to.</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getPeerClusterZnode()">getPeerClusterZnode</a></strong>()</code>
<div class="block">Get the id that the source is replicating to</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html" title="class in org.apache.hadoop.hbase.replication.regionserver">MetricsSource</a></code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getSourceMetrics()">getSourceMetrics</a></strong>()</code>
<div class="block">Get Replication Source Metrics</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getStats()">getStats</a></strong>()</code>
<div class="block">Get a string representation of the current statistics
for this source</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#init(org.apache.hadoop.conf.Configuration,%20org.apache.hadoop.fs.FileSystem,%20org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager,%20org.apache.hadoop.hbase.replication.ReplicationQueues,%20org.apache.hadoop.hbase.replication.ReplicationPeers,%20org.apache.hadoop.hbase.Stoppable,%20java.lang.String,%20java.util.UUID,%20org.apache.hadoop.hbase.replication.ReplicationEndpoint,%20org.apache.hadoop.hbase.replication.regionserver.MetricsSource)">init</a></strong>(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
@@ -374,53 +382,53 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<div class="block">Instantiation method used by region servers</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code>protected boolean</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#isPeerEnabled()">isPeerEnabled</a></strong>()</code>
<div class="block">check whether the peer is enabled or not</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code>private boolean</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#isSourceActive()">isSourceActive</a></strong>()</code> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#run()">run</a></strong>()</code> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code>protected boolean</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#sleepForRetries(java.lang.String,%20int)">sleepForRetries</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> msg,
int sleepMultiplier)</code>
<div class="block">Do the sleeping logic</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#startup()">startup</a></strong>()</code>
<div class="block">Start the replication</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#terminate(java.lang.String)">terminate</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> reason)</code>
<div class="block">End the replication</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#terminate(java.lang.String,%20java.lang.Exception)">terminate</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> reason,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a> cause)</code>
<div class="block">End the replication</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#terminate(java.lang.String,%20java.lang.Exception,%20boolean)">terminate</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> reason,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a> cause,
boolean join)</code> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code>private void</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#uninitialize()">uninitialize</a></strong>()</code> </td>
</tr>
@@ -459,7 +467,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<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/ReplicationSource.html#line.85">LOG</a></pre>
+<pre>private static final org.apache.commons.logging.Log <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.89">LOG</a></pre>
</li>
</ul>
<a name="queues">
@@ -468,7 +476,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>queues</h4>
-<pre>private <a href="http://docs.oracle.com/javase/7/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/7/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/7/docs/api/java/util/concurrent/PriorityBlockingQueue.html?is-external=true" title="class or interface in java.util.concurrent">PriorityBlockingQueue</a><org.apache.hadoop.fs.Path>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.88">queues</a></pre>
+<pre>private <a href="http://docs.oracle.com/javase/7/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/7/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/7/docs/api/java/util/concurrent/PriorityBlockingQueue.html?is-external=true" title="class or interface in java.util.concurrent">PriorityBlockingQueue</a><org.apache.hadoop.fs.Path>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.92">queues</a></pre>
</li>
</ul>
<a name="queueSizePerGroup">
@@ -477,7 +485,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>queueSizePerGroup</h4>
-<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.91">queueSizePerGroup</a></pre>
+<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.95">queueSizePerGroup</a></pre>
</li>
</ul>
<a name="replicationQueues">
@@ -486,7 +494,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>replicationQueues</h4>
-<pre>private <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/ReplicationSource.html#line.92">replicationQueues</a></pre>
+<pre>private <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/ReplicationSource.html#line.96">replicationQueues</a></pre>
</li>
</ul>
<a name="replicationPeers">
@@ -495,7 +503,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>replicationPeers</h4>
-<pre>private <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/ReplicationSource.html#line.93">replicationPeers</a></pre>
+<pre>private <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/ReplicationSource.html#line.97">replicationPeers</a></pre>
</li>
</ul>
<a name="conf">
@@ -504,7 +512,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>conf</h4>
-<pre>private org.apache.hadoop.conf.Configuration <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.95">conf</a></pre>
+<pre>private org.apache.hadoop.conf.Configuration <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.99">conf</a></pre>
</li>
</ul>
<a name="replicationQueueInfo">
@@ -513,7 +521,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>replicationQueueInfo</h4>
-<pre>private <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueInfo.html" title="class in org.apache.hadoop.hbase.replication">ReplicationQueueInfo</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.96">replicationQueueInfo</a></pre>
+<pre>private <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueInfo.html" title="class in org.apache.hadoop.hbase.replication">ReplicationQueueInfo</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.100">replicationQueueInfo</a></pre>
</li>
</ul>
<a name="peerId">
@@ -522,7 +530,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>peerId</h4>
-<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.98">peerId</a></pre>
+<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.102">peerId</a></pre>
</li>
</ul>
<a name="manager">
@@ -531,7 +539,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>manager</h4>
-<pre>private <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.100">manager</a></pre>
+<pre>private <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.104">manager</a></pre>
</li>
</ul>
<a name="stopper">
@@ -540,7 +548,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>stopper</h4>
-<pre>private <a href="../../../../../../org/apache/hadoop/hbase/Stoppable.html" title="interface in org.apache.hadoop.hbase">Stoppable</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.102">stopper</a></pre>
+<pre>private <a href="../../../../../../org/apache/hadoop/hbase/Stoppable.html" title="interface in org.apache.hadoop.hbase">Stoppable</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.106">stopper</a></pre>
</li>
</ul>
<a name="sleepForRetries">
@@ -549,7 +557,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>sleepForRetries</h4>
-<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.104">sleepForRetries</a></pre>
+<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.108">sleepForRetries</a></pre>
</li>
</ul>
<a name="replicationQueueSizeCapacity">
@@ -558,7 +566,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>replicationQueueSizeCapacity</h4>
-<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.106">replicationQueueSizeCapacity</a></pre>
+<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.110">replicationQueueSizeCapacity</a></pre>
</li>
</ul>
<a name="replicationQueueNbCapacity">
@@ -567,7 +575,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>replicationQueueNbCapacity</h4>
-<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.108">replicationQueueNbCapacity</a></pre>
+<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.112">replicationQueueNbCapacity</a></pre>
</li>
</ul>
<a name="fs">
@@ -576,7 +584,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>fs</h4>
-<pre>private org.apache.hadoop.fs.FileSystem <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.109">fs</a></pre>
+<pre>private org.apache.hadoop.fs.FileSystem <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.113">fs</a></pre>
</li>
</ul>
<a name="clusterId">
@@ -585,7 +593,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>clusterId</h4>
-<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/UUID.html?is-external=true" title="class or interface in java.util">UUID</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.111">clusterId</a></pre>
+<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/UUID.html?is-external=true" title="class or interface in java.util">UUID</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.115">clusterId</a></pre>
</li>
</ul>
<a name="peerClusterId">
@@ -594,7 +602,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>peerClusterId</h4>
-<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/UUID.html?is-external=true" title="class or interface in java.util">UUID</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.113">peerClusterId</a></pre>
+<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/UUID.html?is-external=true" title="class or interface in java.util">UUID</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.117">peerClusterId</a></pre>
</li>
</ul>
<a name="totalReplicatedEdits">
@@ -603,7 +611,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>totalReplicatedEdits</h4>
-<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true" title="class or interface in java.util.concurrent.atomic">AtomicLong</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.115">totalReplicatedEdits</a></pre>
+<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true" title="class or interface in java.util.concurrent.atomic">AtomicLong</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.119">totalReplicatedEdits</a></pre>
</li>
</ul>
<a name="totalReplicatedOperations">
@@ -612,7 +620,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>totalReplicatedOperations</h4>
-<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true" title="class or interface in java.util.concurrent.atomic">AtomicLong</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.117">totalReplicatedOperations</a></pre>
+<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true" title="class or interface in java.util.concurrent.atomic">AtomicLong</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.121">totalReplicatedOperations</a></pre>
</li>
</ul>
<a name="peerClusterZnode">
@@ -621,7 +629,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>peerClusterZnode</h4>
-<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.119">peerClusterZnode</a></pre>
+<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.123">peerClusterZnode</a></pre>
</li>
</ul>
<a name="maxRetriesMultiplier">
@@ -630,7 +638,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>maxRetriesMultiplier</h4>
-<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.121">maxRetriesMultiplier</a></pre>
+<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.125">maxRetriesMultiplier</a></pre>
</li>
</ul>
<a name="sourceRunning">
@@ -639,7 +647,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>sourceRunning</h4>
-<pre>private volatile boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.123">sourceRunning</a></pre>
+<pre>private volatile boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.127">sourceRunning</a></pre>
</li>
</ul>
<a name="metrics">
@@ -648,7 +656,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>metrics</h4>
-<pre>private <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html" title="class in org.apache.hadoop.hbase.replication.regionserver">MetricsSource</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.125">metrics</a></pre>
+<pre>private <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html" title="class in org.apache.hadoop.hbase.replication.regionserver">MetricsSource</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.129">metrics</a></pre>
</li>
</ul>
<a name="logQueueWarnThreshold">
@@ -657,7 +665,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>logQueueWarnThreshold</h4>
-<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.127">logQueueWarnThreshold</a></pre>
+<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.131">logQueueWarnThreshold</a></pre>
</li>
</ul>
<a name="replicationEndpoint">
@@ -666,7 +674,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>replicationEndpoint</h4>
-<pre>private <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationEndpoint.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationEndpoint</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.129">replicationEndpoint</a></pre>
+<pre>private <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationEndpoint.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationEndpoint</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.133">replicationEndpoint</a></pre>
</li>
</ul>
<a name="walEntryFilter">
@@ -675,7 +683,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>walEntryFilter</h4>
-<pre>private <a href="../../../../../../org/apache/hadoop/hbase/replication/WALEntryFilter.html" title="interface in org.apache.hadoop.hbase.replication">WALEntryFilter</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.131">walEntryFilter</a></pre>
+<pre>private <a href="../../../../../../org/apache/hadoop/hbase/replication/WALEntryFilter.html" title="interface in org.apache.hadoop.hbase.replication">WALEntryFilter</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.135">walEntryFilter</a></pre>
</li>
</ul>
<a name="throttler">
@@ -684,7 +692,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>throttler</h4>
-<pre>private <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationThrottler.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationThrottler</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.133">throttler</a></pre>
+<pre>private <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationThrottler.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationThrottler</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.137">throttler</a></pre>
</li>
</ul>
<a name="logQueueSize">
@@ -693,7 +701,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>logQueueSize</h4>
-<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true" title="class or interface in java.util.concurrent.atomic">AtomicInteger</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.134">logQueueSize</a></pre>
+<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true" title="class or interface in java.util.concurrent.atomic">AtomicInteger</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.138">logQueueSize</a></pre>
</li>
</ul>
<a name="workerThreads">
@@ -702,7 +710,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockListLast">
<li class="blockList">
<h4>workerThreads</h4>
-<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ConcurrentHashMap.html?is-external=true" title="class or interface in java.util.concurrent">ConcurrentHashMap</a><<a href="http://docs.oracle.com/javase/7/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/ReplicationSource.ReplicationSourceWorkerThread.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSource.ReplicationSourceWorkerThread</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.135">workerThreads</a></pre>
+<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ConcurrentHashMap.html?is-external=true" title="class or interface in java.util.concurrent">ConcurrentHashMap</a><<a href="http://docs.oracle.com/javase/7/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/ReplicationSource.ReplicationSourceWorkerThread.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSource.ReplicationSourceWorkerThread</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.139">workerThreads</a></pre>
</li>
</ul>
</li>
@@ -719,7 +727,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockListLast">
<li class="blockList">
<h4>ReplicationSource</h4>
-<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.82">ReplicationSource</a>()</pre>
+<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.86">ReplicationSource</a>()</pre>
</li>
</ul>
</li>
@@ -736,7 +744,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>init</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.152">init</a>(org.apache.hadoop.conf.Configuration conf,
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.156">init</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,
@@ -762,7 +770,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>decorateConf</h4>
-<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.187">decorateConf</a>()</pre>
+<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.191">decorateConf</a>()</pre>
</li>
</ul>
<a name="enqueueLog(org.apache.hadoop.fs.Path)">
@@ -771,7 +779,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>enqueueLog</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.195">enqueueLog</a>(org.apache.hadoop.fs.Path log)</pre>
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.199">enqueueLog</a>(org.apache.hadoop.fs.Path log)</pre>
<div class="block"><strong>Description copied from interface: <code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#enqueueLog(org.apache.hadoop.fs.Path)">ReplicationSourceInterface</a></code></strong></div>
<div class="block">Add a log to the list of logs to replicate</div>
<dl>
@@ -780,13 +788,33 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<dt><span class="strong">Parameters:</span></dt><dd><code>log</code> - path to the log to replicate</dd></dl>
</li>
</ul>
+<a name="addHFileRefs(org.apache.hadoop.hbase.TableName, byte[], java.util.List)">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>addHFileRefs</h4>
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.231">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/7/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/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>> files)
+ throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre>
+<div class="block"><strong>Description copied from interface: <code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#addHFileRefs(org.apache.hadoop.hbase.TableName,%20byte[],%20java.util.List)">ReplicationSourceInterface</a></code></strong></div>
+<div class="block">Add hfile names to the queue to be replicated.</div>
+<dl>
+<dt><strong>Specified by:</strong></dt>
+<dd><code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#addHFileRefs(org.apache.hadoop.hbase.TableName,%20byte[],%20java.util.List)">addHFileRefs</a></code> in interface <code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html" title="interface in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a></code></dd>
+<dt><span class="strong">Parameters:</span></dt><dd><code>tableName</code> - Name of the table these files belongs to</dd><dd><code>family</code> - Name of the family these files belong to</dd><dd><code>files</code> - files whose names needs to be added to the queue to be replicated</dd>
+<dt><span class="strong">Throws:</span></dt>
+<dd><code><a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></code> - If failed to add hfile references</dd></dl>
+</li>
+</ul>
<a name="uninitialize()">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>uninitialize</h4>
-<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.226">uninitialize</a>()</pre>
+<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.258">uninitialize</a>()</pre>
</li>
</ul>
<a name="run()">
@@ -795,7 +823,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>run</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.236">run</a>()</pre>
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.268">run</a>()</pre>
<dl>
<dt><strong>Specified by:</strong></dt>
<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable.html?is-external=true#run()" title="class or interface in java.lang">run</a></code> in interface <code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a></code></dd>
@@ -810,7 +838,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>sleepForRetries</h4>
-<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.302">sleepForRetries</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> msg,
+<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.334">sleepForRetries</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> msg,
int sleepMultiplier)</pre>
<div class="block">Do the sleeping logic</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>msg</code> - Why we sleep</dd><dd><code>sleepMultiplier</code> - by how many times the default sleeping time is augmented</dd>
@@ -823,7 +851,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>isPeerEnabled</h4>
-<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.320">isPeerEnabled</a>()</pre>
+<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.352">isPeerEnabled</a>()</pre>
<div class="block">check whether the peer is enabled or not</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>true if the peer is enabled, otherwise false</dd></dl>
</li>
@@ -834,7 +862,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>startup</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.325">startup</a>()</pre>
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.357">startup</a>()</pre>
<div class="block"><strong>Description copied from interface: <code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#startup()">ReplicationSourceInterface</a></code></strong></div>
<div class="block">Start the replication</div>
<dl>
@@ -849,7 +877,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>terminate</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.338">terminate</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> reason)</pre>
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.370">terminate</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> reason)</pre>
<div class="block"><strong>Description copied from interface: <code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#terminate(java.lang.String)">ReplicationSourceInterface</a></code></strong></div>
<div class="block">End the replication</div>
<dl>
@@ -864,7 +892,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>terminate</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.343">terminate</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> reason,
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.375">terminate</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> reason,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a> cause)</pre>
<div class="block"><strong>Description copied from interface: <code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#terminate(java.lang.String,%20java.lang.Exception)">ReplicationSourceInterface</a></code></strong></div>
<div class="block">End the replication</div>
@@ -880,7 +908,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>terminate</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.347">terminate</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> reason,
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.379">terminate</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> reason,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a> cause,
boolean join)</pre>
</li>
@@ -891,7 +919,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>getPeerClusterZnode</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.382">getPeerClusterZnode</a>()</pre>
+<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.414">getPeerClusterZnode</a>()</pre>
<div class="block"><strong>Description copied from interface: <code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getPeerClusterZnode()">ReplicationSourceInterface</a></code></strong></div>
<div class="block">Get the id that the source is replicating to</div>
<dl>
@@ -906,7 +934,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>getPeerClusterId</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.387">getPeerClusterId</a>()</pre>
+<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.419">getPeerClusterId</a>()</pre>
<div class="block"><strong>Description copied from interface: <code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getPeerClusterId()">ReplicationSourceInterface</a></code></strong></div>
<div class="block">Get the id that the source is replicating to.</div>
<dl>
@@ -921,7 +949,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>getCurrentPath</h4>
-<pre>public org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.392">getCurrentPath</a>()</pre>
+<pre>public org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.424">getCurrentPath</a>()</pre>
<div class="block"><strong>Description copied from interface: <code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getCurrentPath()">ReplicationSourceInterface</a></code></strong></div>
<div class="block">Get the current log that's replicated</div>
<dl>
@@ -936,7 +964,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>isSourceActive</h4>
-<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.400">isSourceActive</a>()</pre>
+<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.432">isSourceActive</a>()</pre>
</li>
</ul>
<a name="getStats()">
@@ -945,7 +973,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockList">
<li class="blockList">
<h4>getStats</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.427">getStats</a>()</pre>
+<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.459">getStats</a>()</pre>
<div class="block"><strong>Description copied from interface: <code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getStats()">ReplicationSourceInterface</a></code></strong></div>
<div class="block">Get a string representation of the current statistics
for this source</div>
@@ -961,7 +989,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<ul class="blockListLast">
<li class="blockList">
<h4>getSourceMetrics</h4>
-<pre>public <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html" title="class in org.apache.hadoop.hbase.replication.regionserver">MetricsSource</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.451">getSourceMetrics</a>()</pre>
+<pre>public <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html" title="class in org.apache.hadoop.hbase.replication.regionserver">MetricsSource</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.483">getSourceMetrics</a>()</pre>
<div class="block">Get Replication Source Metrics</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>sourceMetrics</dd></dl>
</li>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f68717a0/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html
----------------------------------------------------------------------
diff --git a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html
index b687f0a..afe8977 100644
--- a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html
+++ b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html
@@ -92,7 +92,7 @@
<hr>
<br>
<pre><a href="../../../../../../org/apache/hadoop/hbase/classification/InterfaceAudience.Private.html" title="annotation in org.apache.hadoop.hbase.classification">@InterfaceAudience.Private</a>
-public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.37">ReplicationSourceInterface</a></pre>
+public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.40">ReplicationSourceInterface</a></pre>
<div class="block">Interface that defines a replication source</div>
</li>
</ul>
@@ -114,36 +114,44 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
+<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#addHFileRefs(org.apache.hadoop.hbase.TableName,%20byte[],%20java.util.List)">addHFileRefs</a></strong>(<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/7/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/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>> files)</code>
+<div class="block">Add hfile names to the queue to be replicated.</div>
+</td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#enqueueLog(org.apache.hadoop.fs.Path)">enqueueLog</a></strong>(org.apache.hadoop.fs.Path log)</code>
<div class="block">Add a log to the list of logs to replicate</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code>org.apache.hadoop.fs.Path</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getCurrentPath()">getCurrentPath</a></strong>()</code>
<div class="block">Get the current log that's replicated</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getPeerClusterId()">getPeerClusterId</a></strong>()</code>
<div class="block">Get the id that the source is replicating to.</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getPeerClusterZnode()">getPeerClusterZnode</a></strong>()</code>
<div class="block">Get the id that the source is replicating to</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getStats()">getStats</a></strong>()</code>
<div class="block">Get a string representation of the current statistics
for this source</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#init(org.apache.hadoop.conf.Configuration,%20org.apache.hadoop.fs.FileSystem,%20org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager,%20org.apache.hadoop.hbase.replication.ReplicationQueues,%20org.apache.hadoop.hbase.replication.ReplicationPeers,%20org.apache.hadoop.hbase.Stoppable,%20java.lang.String,%20java.util.UUID,%20org.apache.hadoop.hbase.replication.ReplicationEndpoint,%20org.apache.hadoop.hbase.replication.regionserver.MetricsSource)">init</a></strong>(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
@@ -158,19 +166,19 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep
<div class="block">Initializer for the source</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#startup()">startup</a></strong>()</code>
<div class="block">Start the replication</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#terminate(java.lang.String)">terminate</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> reason)</code>
<div class="block">End the replication</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#terminate(java.lang.String,%20java.lang.Exception)">terminate</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> reason,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a> cause)</code>
@@ -198,7 +206,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep
<ul class="blockList">
<li class="blockList">
<h4>init</h4>
-<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.51">init</a>(org.apache.hadoop.conf.Configuration conf,
+<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.54">init</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,
@@ -221,7 +229,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep
<ul class="blockList">
<li class="blockList">
<h4>enqueueLog</h4>
-<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.61">enqueueLog</a>(org.apache.hadoop.fs.Path log)</pre>
+<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.64">enqueueLog</a>(org.apache.hadoop.fs.Path log)</pre>
<div class="block">Add a log to the list of logs to replicate</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>log</code> - path to the log to replicate</dd></dl>
</li>
@@ -232,7 +240,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep
<ul class="blockList">
<li class="blockList">
<h4>getCurrentPath</h4>
-<pre>org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.67">getCurrentPath</a>()</pre>
+<pre>org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.70">getCurrentPath</a>()</pre>
<div class="block">Get the current log that's replicated</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>the current log</dd></dl>
</li>
@@ -243,7 +251,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep
<ul class="blockList">
<li class="blockList">
<h4>startup</h4>
-<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.72">startup</a>()</pre>
+<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.75">startup</a>()</pre>
<div class="block">Start the replication</div>
</li>
</ul>
@@ -253,7 +261,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep
<ul class="blockList">
<li class="blockList">
<h4>terminate</h4>
-<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.78">terminate</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> reason)</pre>
+<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.81">terminate</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> reason)</pre>
<div class="block">End the replication</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>reason</code> - why it's terminating</dd></dl>
</li>
@@ -264,7 +272,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep
<ul class="blockList">
<li class="blockList">
<h4>terminate</h4>
-<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.85">terminate</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> reason,
+<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.88">terminate</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> reason,
<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a> cause)</pre>
<div class="block">End the replication</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>reason</code> - why it's terminating</dd><dd><code>cause</code> - the error that's causing it</dd></dl>
@@ -276,7 +284,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep
<ul class="blockList">
<li class="blockList">
<h4>getPeerClusterZnode</h4>
-<pre><a href="http://docs.oracle.com/javase/7/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/ReplicationSourceInterface.html#line.92">getPeerClusterZnode</a>()</pre>
+<pre><a href="http://docs.oracle.com/javase/7/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/ReplicationSourceInterface.html#line.95">getPeerClusterZnode</a>()</pre>
<div class="block">Get the id that the source is replicating to</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>peer cluster id</dd></dl>
</li>
@@ -287,7 +295,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep
<ul class="blockList">
<li class="blockList">
<h4>getPeerClusterId</h4>
-<pre><a href="http://docs.oracle.com/javase/7/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/ReplicationSourceInterface.html#line.99">getPeerClusterId</a>()</pre>
+<pre><a href="http://docs.oracle.com/javase/7/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/ReplicationSourceInterface.html#line.102">getPeerClusterId</a>()</pre>
<div class="block">Get the id that the source is replicating to.</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>peer cluster id</dd></dl>
</li>
@@ -295,15 +303,31 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep
<a name="getStats()">
<!-- -->
</a>
-<ul class="blockListLast">
+<ul class="blockList">
<li class="blockList">
<h4>getStats</h4>
-<pre><a href="http://docs.oracle.com/javase/7/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/ReplicationSourceInterface.html#line.106">getStats</a>()</pre>
+<pre><a href="http://docs.oracle.com/javase/7/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/ReplicationSourceInterface.html#line.109">getStats</a>()</pre>
<div class="block">Get a string representation of the current statistics
for this source</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>printable stats</dd></dl>
</li>
</ul>
+<a name="addHFileRefs(org.apache.hadoop.hbase.TableName, byte[], java.util.List)">
+<!-- -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>addHFileRefs</h4>
+<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.118">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/7/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/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>> files)
+ throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre>
+<div class="block">Add hfile names to the queue to be replicated.</div>
+<dl><dt><span class="strong">Parameters:</span></dt><dd><code>tableName</code> - Name of the table these files belongs to</dd><dd><code>family</code> - Name of the family these files belong to</dd><dd><code>files</code> - files whose names needs to be added to the queue to be replicated</dd>
+<dt><span class="strong">Throws:</span></dt>
+<dd><code><a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></code> - If failed to add hfile references</dd></dl>
+</li>
+</ul>
</li>
</ul>
</li>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f68717a0/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.NodeFailoverWorker.html
----------------------------------------------------------------------
diff --git a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.NodeFailoverWorker.html b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.NodeFailoverWorker.html
index 003793a..bc8b433 100644
--- a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.NodeFailoverWorker.html
+++ b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.NodeFailoverWorker.html
@@ -108,7 +108,7 @@
</dl>
<hr>
<br>
-<pre> class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.595">ReplicationSourceManager.NodeFailoverWorker</a>
+<pre> class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.605">ReplicationSourceManager.NodeFailoverWorker</a>
extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?is-external=true" title="class or interface in java.lang">Thread</a></pre>
<div class="block">Class responsible to setup new ReplicationSources to take care of the
queues from dead region servers.</div>
@@ -242,7 +242,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>rsZnode</h4>
-<pre>private <a href="http://docs.oracle.com/javase/7/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.NodeFailoverWorker.html#line.597">rsZnode</a></pre>
+<pre>private <a href="http://docs.oracle.com/javase/7/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.NodeFailoverWorker.html#line.607">rsZnode</a></pre>
</li>
</ul>
<a name="rq">
@@ -251,7 +251,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>rq</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.NodeFailoverWorker.html#line.598">rq</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.NodeFailoverWorker.html#line.608">rq</a></pre>
</li>
</ul>
<a name="rp">
@@ -260,7 +260,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>rp</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.NodeFailoverWorker.html#line.599">rp</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.NodeFailoverWorker.html#line.609">rp</a></pre>
</li>
</ul>
<a name="clusterId">
@@ -269,7 +269,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockListLast">
<li class="blockList">
<h4>clusterId</h4>
-<pre>private final <a href="http://docs.oracle.com/javase/7/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.NodeFailoverWorker.html#line.600">clusterId</a></pre>
+<pre>private final <a href="http://docs.oracle.com/javase/7/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.NodeFailoverWorker.html#line.610">clusterId</a></pre>
</li>
</ul>
</li>
@@ -286,7 +286,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockListLast">
<li class="blockList">
<h4>ReplicationSourceManager.NodeFailoverWorker</h4>
-<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.NodeFailoverWorker.html#line.606">ReplicationSourceManager.NodeFailoverWorker</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> rsZnode,
+<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.NodeFailoverWorker.html#line.616">ReplicationSourceManager.NodeFailoverWorker</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> rsZnode,
<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="http://docs.oracle.com/javase/7/docs/api/java/util/UUID.html?is-external=true" title="class or interface in java.util">UUID</a> clusterId)</pre>
@@ -307,7 +307,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockListLast">
<li class="blockList">
<h4>run</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.NodeFailoverWorker.html#line.616">run</a>()</pre>
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.NodeFailoverWorker.html#line.626">run</a>()</pre>
<dl>
<dt><strong>Specified by:</strong></dt>
<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable.html?is-external=true#run()" title="class or interface in java.lang">run</a></code> in interface <code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a></code></dd>