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>