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 2016/01/29 18:13:29 UTC
[10/51] [partial] hbase-site git commit: Published site at
0de221a19d799ad515f8f4556cacd05e6b4e74f8.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/c6155501/devapidocs/org/apache/hadoop/hbase/regionserver/throttle/package-use.html
----------------------------------------------------------------------
diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/throttle/package-use.html b/devapidocs/org/apache/hadoop/hbase/regionserver/throttle/package-use.html
new file mode 100644
index 0000000..54b33dd
--- /dev/null
+++ b/devapidocs/org/apache/hadoop/hbase/regionserver/throttle/package-use.html
@@ -0,0 +1,228 @@
+<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
+<!-- NewPage -->
+<html lang="en">
+<head>
+<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
+<title>Uses of Package org.apache.hadoop.hbase.regionserver.throttle (Apache HBase 2.0.0-SNAPSHOT API)</title>
+<link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style">
+</head>
+<body>
+<script type="text/javascript"><!--
+ if (location.href.indexOf('is-external=true') == -1) {
+ parent.document.title="Uses of Package org.apache.hadoop.hbase.regionserver.throttle (Apache HBase 2.0.0-SNAPSHOT API)";
+ }
+//-->
+</script>
+<noscript>
+<div>JavaScript is disabled on your browser.</div>
+</noscript>
+<!-- ========= START OF TOP NAVBAR ======= -->
+<div class="topNav"><a name="navbar_top">
+<!-- -->
+</a><a href="#skip-navbar_top" title="Skip navigation links"></a><a name="navbar_top_firstrow">
+<!-- -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../../../../overview-summary.html">Overview</a></li>
+<li><a href="package-summary.html">Package</a></li>
+<li>Class</li>
+<li class="navBarCell1Rev">Use</li>
+<li><a href="package-tree.html">Tree</a></li>
+<li><a href="../../../../../../deprecated-list.html">Deprecated</a></li>
+<li><a href="../../../../../../index-all.html">Index</a></li>
+<li><a href="../../../../../../help-doc.html">Help</a></li>
+</ul>
+</div>
+<div class="subNav">
+<ul class="navList">
+<li>Prev</li>
+<li>Next</li>
+</ul>
+<ul class="navList">
+<li><a href="../../../../../../index.html?org/apache/hadoop/hbase/regionserver/throttle/package-use.html" target="_top">Frames</a></li>
+<li><a href="package-use.html" target="_top">No Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_top">
+<li><a href="../../../../../../allclasses-noframe.html">All Classes</a></li>
+</ul>
+<div>
+<script type="text/javascript"><!--
+ allClassesLink = document.getElementById("allclasses_navbar_top");
+ if(window==top) {
+ allClassesLink.style.display = "block";
+ }
+ else {
+ allClassesLink.style.display = "none";
+ }
+ //-->
+</script>
+</div>
+<a name="skip-navbar_top">
+<!-- -->
+</a></div>
+<!-- ========= END OF TOP NAVBAR ========= -->
+<div class="header">
+<h1 title="Uses of Package org.apache.hadoop.hbase.regionserver.throttle" class="title">Uses of Package<br>org.apache.hadoop.hbase.regionserver.throttle</h1>
+</div>
+<div class="contentContainer">
+<ul class="blockList">
+<li class="blockList">
+<table border="0" cellpadding="3" cellspacing="0" summary="Use table, listing packages, and an explanation">
+<caption><span>Packages that use <a href="../../../../../../org/apache/hadoop/hbase/regionserver/throttle/package-summary.html">org.apache.hadoop.hbase.regionserver.throttle</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Package</th>
+<th class="colLast" scope="col">Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><a href="#org.apache.hadoop.hbase.mob">org.apache.hadoop.hbase.mob</a></td>
+<td class="colLast"> </td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><a href="#org.apache.hadoop.hbase.regionserver">org.apache.hadoop.hbase.regionserver</a></td>
+<td class="colLast"> </td>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><a href="#org.apache.hadoop.hbase.regionserver.compactions">org.apache.hadoop.hbase.regionserver.compactions</a></td>
+<td class="colLast"> </td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><a href="#org.apache.hadoop.hbase.regionserver.throttle">org.apache.hadoop.hbase.regionserver.throttle</a></td>
+<td class="colLast"> </td>
+</tr>
+</tbody>
+</table>
+</li>
+<li class="blockList"><a name="org.apache.hadoop.hbase.mob">
+<!-- -->
+</a>
+<table border="0" cellpadding="3" cellspacing="0" summary="Use table, listing classes, and an explanation">
+<caption><span>Classes in <a href="../../../../../../org/apache/hadoop/hbase/regionserver/throttle/package-summary.html">org.apache.hadoop.hbase.regionserver.throttle</a> used by <a href="../../../../../../org/apache/hadoop/hbase/mob/package-summary.html">org.apache.hadoop.hbase.mob</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colOne" scope="col">Class and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colOne"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/throttle/class-use/ThroughputController.html#org.apache.hadoop.hbase.mob">ThroughputController</a>
+<div class="block">A utility that constrains the total throughput of one or more simultaneous flows by
+ sleeping when necessary.</div>
+</td>
+</tr>
+</tbody>
+</table>
+</li>
+<li class="blockList"><a name="org.apache.hadoop.hbase.regionserver">
+<!-- -->
+</a>
+<table border="0" cellpadding="3" cellspacing="0" summary="Use table, listing classes, and an explanation">
+<caption><span>Classes in <a href="../../../../../../org/apache/hadoop/hbase/regionserver/throttle/package-summary.html">org.apache.hadoop.hbase.regionserver.throttle</a> used by <a href="../../../../../../org/apache/hadoop/hbase/regionserver/package-summary.html">org.apache.hadoop.hbase.regionserver</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colOne" scope="col">Class and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colOne"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/throttle/class-use/ThroughputController.html#org.apache.hadoop.hbase.regionserver">ThroughputController</a>
+<div class="block">A utility that constrains the total throughput of one or more simultaneous flows by
+ sleeping when necessary.</div>
+</td>
+</tr>
+</tbody>
+</table>
+</li>
+<li class="blockList"><a name="org.apache.hadoop.hbase.regionserver.compactions">
+<!-- -->
+</a>
+<table border="0" cellpadding="3" cellspacing="0" summary="Use table, listing classes, and an explanation">
+<caption><span>Classes in <a href="../../../../../../org/apache/hadoop/hbase/regionserver/throttle/package-summary.html">org.apache.hadoop.hbase.regionserver.throttle</a> used by <a href="../../../../../../org/apache/hadoop/hbase/regionserver/compactions/package-summary.html">org.apache.hadoop.hbase.regionserver.compactions</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colOne" scope="col">Class and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colOne"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/throttle/class-use/ThroughputController.html#org.apache.hadoop.hbase.regionserver.compactions">ThroughputController</a>
+<div class="block">A utility that constrains the total throughput of one or more simultaneous flows by
+ sleeping when necessary.</div>
+</td>
+</tr>
+</tbody>
+</table>
+</li>
+<li class="blockList"><a name="org.apache.hadoop.hbase.regionserver.throttle">
+<!-- -->
+</a>
+<table border="0" cellpadding="3" cellspacing="0" summary="Use table, listing classes, and an explanation">
+<caption><span>Classes in <a href="../../../../../../org/apache/hadoop/hbase/regionserver/throttle/package-summary.html">org.apache.hadoop.hbase.regionserver.throttle</a> used by <a href="../../../../../../org/apache/hadoop/hbase/regionserver/throttle/package-summary.html">org.apache.hadoop.hbase.regionserver.throttle</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colOne" scope="col">Class and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colOne"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/throttle/class-use/NoLimitThroughputController.html#org.apache.hadoop.hbase.regionserver.throttle">NoLimitThroughputController</a> </td>
+</tr>
+<tr class="rowColor">
+<td class="colOne"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/throttle/class-use/PressureAwareThroughputController.html#org.apache.hadoop.hbase.regionserver.throttle">PressureAwareThroughputController</a> </td>
+</tr>
+<tr class="altColor">
+<td class="colOne"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/throttle/class-use/PressureAwareThroughputController.ActiveOperation.html#org.apache.hadoop.hbase.regionserver.throttle">PressureAwareThroughputController.ActiveOperation</a>
+<div class="block">Stores the information of one controlled compaction.</div>
+</td>
+</tr>
+<tr class="rowColor">
+<td class="colOne"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/throttle/class-use/ThroughputController.html#org.apache.hadoop.hbase.regionserver.throttle">ThroughputController</a>
+<div class="block">A utility that constrains the total throughput of one or more simultaneous flows by
+ sleeping when necessary.</div>
+</td>
+</tr>
+</tbody>
+</table>
+</li>
+</ul>
+</div>
+<!-- ======= START OF BOTTOM NAVBAR ====== -->
+<div class="bottomNav"><a name="navbar_bottom">
+<!-- -->
+</a><a href="#skip-navbar_bottom" title="Skip navigation links"></a><a name="navbar_bottom_firstrow">
+<!-- -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../../../../overview-summary.html">Overview</a></li>
+<li><a href="package-summary.html">Package</a></li>
+<li>Class</li>
+<li class="navBarCell1Rev">Use</li>
+<li><a href="package-tree.html">Tree</a></li>
+<li><a href="../../../../../../deprecated-list.html">Deprecated</a></li>
+<li><a href="../../../../../../index-all.html">Index</a></li>
+<li><a href="../../../../../../help-doc.html">Help</a></li>
+</ul>
+</div>
+<div class="subNav">
+<ul class="navList">
+<li>Prev</li>
+<li>Next</li>
+</ul>
+<ul class="navList">
+<li><a href="../../../../../../index.html?org/apache/hadoop/hbase/regionserver/throttle/package-use.html" target="_top">Frames</a></li>
+<li><a href="package-use.html" target="_top">No Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_bottom">
+<li><a href="../../../../../../allclasses-noframe.html">All Classes</a></li>
+</ul>
+<div>
+<script type="text/javascript"><!--
+ allClassesLink = document.getElementById("allclasses_navbar_bottom");
+ if(window==top) {
+ allClassesLink.style.display = "block";
+ }
+ else {
+ allClassesLink.style.display = "none";
+ }
+ //-->
+</script>
+</div>
+<a name="skip-navbar_bottom">
+<!-- -->
+</a></div>
+<!-- ======== END OF BOTTOM NAVBAR ======= -->
+<p class="legalCopy"><small>Copyright © 2007–2016 <a href="http://www.apache.org/">The Apache Software Foundation</a>. All rights reserved.</small></p>
+</body>
+</html>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/c6155501/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-summary.html
----------------------------------------------------------------------
diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-summary.html b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-summary.html
index 303e4d6..c6e14ac 100644
--- a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-summary.html
+++ b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-summary.html
@@ -35,7 +35,7 @@
</div>
<div class="subNav">
<ul class="navList">
-<li><a href="../../../../../../org/apache/hadoop/hbase/regionserver/snapshot/package-summary.html">Prev Package</a></li>
+<li><a href="../../../../../../org/apache/hadoop/hbase/regionserver/throttle/package-summary.html">Prev Package</a></li>
<li><a href="../../../../../../org/apache/hadoop/hbase/replication/package-summary.html">Next Package</a></li>
</ul>
<ul class="navList">
@@ -405,7 +405,7 @@
</div>
<div class="subNav">
<ul class="navList">
-<li><a href="../../../../../../org/apache/hadoop/hbase/regionserver/snapshot/package-summary.html">Prev Package</a></li>
+<li><a href="../../../../../../org/apache/hadoop/hbase/regionserver/throttle/package-summary.html">Prev Package</a></li>
<li><a href="../../../../../../org/apache/hadoop/hbase/replication/package-summary.html">Next Package</a></li>
</ul>
<ul class="navList">
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/c6155501/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html
----------------------------------------------------------------------
diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html
index 6044822..ec7b7b7 100644
--- a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html
+++ b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html
@@ -35,7 +35,7 @@
</div>
<div class="subNav">
<ul class="navList">
-<li><a href="../../../../../../org/apache/hadoop/hbase/regionserver/snapshot/package-tree.html">Prev</a></li>
+<li><a href="../../../../../../org/apache/hadoop/hbase/regionserver/throttle/package-tree.html">Prev</a></li>
<li><a href="../../../../../../org/apache/hadoop/hbase/replication/package-tree.html">Next</a></li>
</ul>
<ul class="navList">
@@ -283,7 +283,7 @@
</div>
<div class="subNav">
<ul class="navList">
-<li><a href="../../../../../../org/apache/hadoop/hbase/regionserver/snapshot/package-tree.html">Prev</a></li>
+<li><a href="../../../../../../org/apache/hadoop/hbase/regionserver/throttle/package-tree.html">Prev</a></li>
<li><a href="../../../../../../org/apache/hadoop/hbase/replication/package-tree.html">Next</a></li>
</ul>
<ul class="navList">
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/c6155501/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html
----------------------------------------------------------------------
diff --git a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html
index 689f2a7..d6d982c 100644
--- a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html
+++ b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html
@@ -103,7 +103,7 @@
</dl>
<hr>
<br>
-<pre>public static class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.440">ReplicationSource.LogsComparator</a>
+<pre>public static class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.442">ReplicationSource.LogsComparator</a>
extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>
implements <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Comparator.html?is-external=true" title="class or interface in java.util">Comparator</a><org.apache.hadoop.fs.Path></pre>
<div class="block">Comparator used to compare logs together based on their start time</div>
@@ -148,7 +148,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Comparato
org.apache.hadoop.fs.Path o2)</code> </td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><code>private long</code></td>
+<td class="colFirst"><code>private static long</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html#getTS(org.apache.hadoop.fs.Path)">getTS</a></strong>(org.apache.hadoop.fs.Path p)</code>
<div class="block">Split a path to get the start time
For example: 10.20.20.171%3A60020.1277499063250</div>
@@ -189,7 +189,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Comparato
<ul class="blockListLast">
<li class="blockList">
<h4>ReplicationSource.LogsComparator</h4>
-<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html#line.440">ReplicationSource.LogsComparator</a>()</pre>
+<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html#line.442">ReplicationSource.LogsComparator</a>()</pre>
</li>
</ul>
</li>
@@ -206,7 +206,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Comparato
<ul class="blockList">
<li class="blockList">
<h4>compare</h4>
-<pre>public int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html#line.443">compare</a>(org.apache.hadoop.fs.Path o1,
+<pre>public int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html#line.445">compare</a>(org.apache.hadoop.fs.Path o1,
org.apache.hadoop.fs.Path o2)</pre>
<dl>
<dt><strong>Specified by:</strong></dt>
@@ -220,7 +220,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Comparato
<ul class="blockListLast">
<li class="blockList">
<h4>getTS</h4>
-<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html#line.453">getTS</a>(org.apache.hadoop.fs.Path p)</pre>
+<pre>private static long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html#line.455">getTS</a>(org.apache.hadoop.fs.Path p)</pre>
<div class="block">Split a path to get the start time
For example: 10.20.20.171%3A60020.1277499063250</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>p</code> - path to split</dd>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/c6155501/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html
----------------------------------------------------------------------
diff --git a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html
index aaa3ff8..f6effe2 100644
--- a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html
+++ b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html
@@ -108,7 +108,7 @@
</dl>
<hr>
<br>
-<pre>public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.488">ReplicationSource.ReplicationSourceWorkerThread</a>
+<pre>public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.490">ReplicationSource.ReplicationSourceWorkerThread</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>
</li>
</ul>
@@ -286,25 +286,30 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
</td>
</tr>
<tr class="altColor">
+<td class="colFirst"><code>private void</code></td>
+<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#recoverLease(org.apache.hadoop.conf.Configuration,%20org.apache.hadoop.fs.Path)">recoverLease</a></strong>(org.apache.hadoop.conf.Configuration conf,
+ org.apache.hadoop.fs.Path path)</code> </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/ReplicationSource.ReplicationSourceWorkerThread.html#run()">run</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.ReplicationSourceWorkerThread.html#setWorkerRunning(boolean)">setWorkerRunning</a></strong>(boolean workerRunning)</code> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code>protected void</code></td>
<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#shipEdits(boolean,%20java.util.List)">shipEdits</a></strong>(boolean currentWALisBeingWrittenTo,
<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="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a>> entries)</code>
<div class="block">Do the shipping logic</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.ReplicationSourceWorkerThread.html#startup()">startup</a></strong>()</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.ReplicationSourceWorkerThread.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> </td>
@@ -344,7 +349,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>source</h4>
-<pre><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSource</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.489">source</a></pre>
+<pre><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSource</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.491">source</a></pre>
</li>
</ul>
<a name="walGroupId">
@@ -353,7 +358,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>walGroupId</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/ReplicationSource.ReplicationSourceWorkerThread.html#line.490">walGroupId</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/ReplicationSource.ReplicationSourceWorkerThread.html#line.492">walGroupId</a></pre>
</li>
</ul>
<a name="queue">
@@ -362,7 +367,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>queue</h4>
-<pre><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.ReplicationSourceWorkerThread.html#line.491">queue</a></pre>
+<pre><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.ReplicationSourceWorkerThread.html#line.493">queue</a></pre>
</li>
</ul>
<a name="replicationQueueInfo">
@@ -371,7 +376,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>replicationQueueInfo</h4>
-<pre><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.ReplicationSourceWorkerThread.html#line.492">replicationQueueInfo</a></pre>
+<pre><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.ReplicationSourceWorkerThread.html#line.494">replicationQueueInfo</a></pre>
</li>
</ul>
<a name="reader">
@@ -380,7 +385,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>reader</h4>
-<pre>private <a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Reader.html" title="interface in org.apache.hadoop.hbase.wal">WAL.Reader</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.494">reader</a></pre>
+<pre>private <a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Reader.html" title="interface in org.apache.hadoop.hbase.wal">WAL.Reader</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.496">reader</a></pre>
</li>
</ul>
<a name="lastLoggedPosition">
@@ -389,7 +394,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>lastLoggedPosition</h4>
-<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.496">lastLoggedPosition</a></pre>
+<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.498">lastLoggedPosition</a></pre>
</li>
</ul>
<a name="currentPath">
@@ -398,7 +403,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>currentPath</h4>
-<pre>private volatile org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.498">currentPath</a></pre>
+<pre>private volatile org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.500">currentPath</a></pre>
</li>
</ul>
<a name="repLogReader">
@@ -407,7 +412,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>repLogReader</h4>
-<pre>private <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationWALReaderManager.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationWALReaderManager</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.500">repLogReader</a></pre>
+<pre>private <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationWALReaderManager.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationWALReaderManager</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.502">repLogReader</a></pre>
</li>
</ul>
<a name="currentNbOperations">
@@ -416,7 +421,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>currentNbOperations</h4>
-<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.502">currentNbOperations</a></pre>
+<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.504">currentNbOperations</a></pre>
</li>
</ul>
<a name="currentSize">
@@ -425,7 +430,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>currentSize</h4>
-<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.504">currentSize</a></pre>
+<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.506">currentSize</a></pre>
</li>
</ul>
<a name="workerRunning">
@@ -434,7 +439,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>workerRunning</h4>
-<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.506">workerRunning</a></pre>
+<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.508">workerRunning</a></pre>
</li>
</ul>
<a name="currentNbHFiles">
@@ -443,7 +448,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockListLast">
<li class="blockList">
<h4>currentNbHFiles</h4>
-<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.508">currentNbHFiles</a></pre>
+<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.510">currentNbHFiles</a></pre>
</li>
</ul>
</li>
@@ -460,7 +465,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockListLast">
<li class="blockList">
<h4>ReplicationSource.ReplicationSourceWorkerThread</h4>
-<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.510">ReplicationSource.ReplicationSourceWorkerThread</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> walGroupId,
+<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.512">ReplicationSource.ReplicationSourceWorkerThread</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> walGroupId,
<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> queue,
<a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueInfo.html" title="class in org.apache.hadoop.hbase.replication">ReplicationQueueInfo</a> replicationQueueInfo,
<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSource</a> source)</pre>
@@ -480,7 +485,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>run</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.520">run</a>()</pre>
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.522">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>
@@ -495,7 +500,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>readAllEntriesToReplicateOrNextFile</h4>
-<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.682">readAllEntriesToReplicateOrNextFile</a>(boolean currentWALisBeingWrittenTo,
+<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.684">readAllEntriesToReplicateOrNextFile</a>(boolean currentWALisBeingWrittenTo,
<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="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a>> entries)
throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true" title="class or interface in java.io">IOException</a></pre>
<div class="block">Read all the entries from the current log files and retain those that need to be replicated.
@@ -512,7 +517,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>cleanUpHFileRefs</h4>
-<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.740">cleanUpHFileRefs</a>(<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.regionserver.wal">WALEdit</a> edit)
+<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.742">cleanUpHFileRefs</a>(<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.regionserver.wal">WALEdit</a> edit)
throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true" title="class or interface in java.io">IOException</a></pre>
<dl><dt><span class="strong">Throws:</span></dt>
<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true" title="class or interface in java.io">IOException</a></code></dd></dl>
@@ -524,7 +529,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>getNextPath</h4>
-<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.766">getNextPath</a>()</pre>
+<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.768">getNextPath</a>()</pre>
<div class="block">Poll for the next path</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>true if a path was obtained, false if not</dd></dl>
</li>
@@ -535,19 +540,29 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>openReader</h4>
-<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.793">openReader</a>(int sleepMultiplier)</pre>
+<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.795">openReader</a>(int sleepMultiplier)</pre>
<div class="block">Open a reader on the current path</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>sleepMultiplier</code> - by how many times the default sleeping time is augmented</dd>
<dt><span class="strong">Returns:</span></dt><dd>true if we should continue with that file, false if we are over with it</dd></dl>
</li>
</ul>
+<a name="recoverLease(org.apache.hadoop.conf.Configuration, org.apache.hadoop.fs.Path)">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>recoverLease</h4>
+<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.900">recoverLease</a>(org.apache.hadoop.conf.Configuration conf,
+ org.apache.hadoop.fs.Path path)</pre>
+</li>
+</ul>
<a name="isCurrentLogEmpty()">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>isCurrentLogEmpty</h4>
-<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.900">isCurrentLogEmpty</a>()</pre>
+<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.922">isCurrentLogEmpty</a>()</pre>
</li>
</ul>
<a name="countDistinctRowKeys(org.apache.hadoop.hbase.regionserver.wal.WALEdit)">
@@ -556,7 +571,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>countDistinctRowKeys</h4>
-<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.911">countDistinctRowKeys</a>(<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.regionserver.wal">WALEdit</a> edit)</pre>
+<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.933">countDistinctRowKeys</a>(<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.regionserver.wal">WALEdit</a> edit)</pre>
<div class="block">Count the number of different row keys in the given edit because of mini-batching. We assume
that there's at least one Cell in the WALEdit.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>edit</code> - edit to count row keys from</dd>
@@ -569,7 +584,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>shipEdits</h4>
-<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.946">shipEdits</a>(boolean currentWALisBeingWrittenTo,
+<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.968">shipEdits</a>(boolean currentWALisBeingWrittenTo,
<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="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a>> entries)</pre>
<div class="block">Do the shipping logic</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>currentWALisBeingWrittenTo</code> - was the current WAL being (seemingly)
@@ -582,7 +597,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>processEndOfFile</h4>
-<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1036">processEndOfFile</a>()</pre>
+<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1058">processEndOfFile</a>()</pre>
<div class="block">If the queue isn't empty, switch to the next one Else if this is a recovered queue, it means
we're done! Else we'll just continue to try reading the log file</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>true if we're done with the current file, false if we should continue trying to read
@@ -595,7 +610,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>startup</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1061">startup</a>()</pre>
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1083">startup</a>()</pre>
</li>
</ul>
<a name="getCurrentPath()">
@@ -604,7 +619,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<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.ReplicationSourceWorkerThread.html#line.1075">getCurrentPath</a>()</pre>
+<pre>public org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1097">getCurrentPath</a>()</pre>
</li>
</ul>
<a name="getCurrentPosition()">
@@ -613,7 +628,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>getCurrentPosition</h4>
-<pre>public long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1079">getCurrentPosition</a>()</pre>
+<pre>public long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1101">getCurrentPosition</a>()</pre>
</li>
</ul>
<a name="isWorkerActive()">
@@ -622,7 +637,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>isWorkerActive</h4>
-<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1083">isWorkerActive</a>()</pre>
+<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1105">isWorkerActive</a>()</pre>
</li>
</ul>
<a name="terminate(java.lang.String, java.lang.Exception)">
@@ -631,7 +646,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockList">
<li class="blockList">
<h4>terminate</h4>
-<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1087">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>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1109">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>
</li>
</ul>
@@ -641,7 +656,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?
<ul class="blockListLast">
<li class="blockList">
<h4>setWorkerRunning</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1100">setWorkerRunning</a>(boolean workerRunning)</pre>
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1122">setWorkerRunning</a>(boolean workerRunning)</pre>
</li>
</ul>
</li>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/c6155501/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 edfd429..530a8bf 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.87">ReplicationSource</a>
+public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.89">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.
@@ -467,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.90">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.92">LOG</a></pre>
</li>
</ul>
<a name="queues">
@@ -476,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.93">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.95">queues</a></pre>
</li>
</ul>
<a name="queueSizePerGroup">
@@ -485,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.96">queueSizePerGroup</a></pre>
+<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.98">queueSizePerGroup</a></pre>
</li>
</ul>
<a name="replicationQueues">
@@ -494,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.97">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.99">replicationQueues</a></pre>
</li>
</ul>
<a name="replicationPeers">
@@ -503,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.98">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.100">replicationPeers</a></pre>
</li>
</ul>
<a name="conf">
@@ -512,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.100">conf</a></pre>
+<pre>private org.apache.hadoop.conf.Configuration <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.102">conf</a></pre>
</li>
</ul>
<a name="replicationQueueInfo">
@@ -521,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.101">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.103">replicationQueueInfo</a></pre>
</li>
</ul>
<a name="peerId">
@@ -530,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.103">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.105">peerId</a></pre>
</li>
</ul>
<a name="manager">
@@ -539,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.105">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.107">manager</a></pre>
</li>
</ul>
<a name="stopper">
@@ -548,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.107">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.109">stopper</a></pre>
</li>
</ul>
<a name="sleepForRetries">
@@ -557,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.109">sleepForRetries</a></pre>
+<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.111">sleepForRetries</a></pre>
</li>
</ul>
<a name="replicationQueueSizeCapacity">
@@ -566,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.111">replicationQueueSizeCapacity</a></pre>
+<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.113">replicationQueueSizeCapacity</a></pre>
</li>
</ul>
<a name="replicationQueueNbCapacity">
@@ -575,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.113">replicationQueueNbCapacity</a></pre>
+<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.115">replicationQueueNbCapacity</a></pre>
</li>
</ul>
<a name="fs">
@@ -584,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.114">fs</a></pre>
+<pre>private org.apache.hadoop.fs.FileSystem <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.116">fs</a></pre>
</li>
</ul>
<a name="clusterId">
@@ -593,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.116">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.118">clusterId</a></pre>
</li>
</ul>
<a name="peerClusterId">
@@ -602,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.118">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.120">peerClusterId</a></pre>
</li>
</ul>
<a name="totalReplicatedEdits">
@@ -611,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.120">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.122">totalReplicatedEdits</a></pre>
</li>
</ul>
<a name="totalReplicatedOperations">
@@ -620,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.122">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.124">totalReplicatedOperations</a></pre>
</li>
</ul>
<a name="peerClusterZnode">
@@ -629,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.124">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.126">peerClusterZnode</a></pre>
</li>
</ul>
<a name="maxRetriesMultiplier">
@@ -638,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.126">maxRetriesMultiplier</a></pre>
+<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.128">maxRetriesMultiplier</a></pre>
</li>
</ul>
<a name="sourceRunning">
@@ -647,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.128">sourceRunning</a></pre>
+<pre>private volatile boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.130">sourceRunning</a></pre>
</li>
</ul>
<a name="metrics">
@@ -656,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.130">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.132">metrics</a></pre>
</li>
</ul>
<a name="logQueueWarnThreshold">
@@ -665,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.132">logQueueWarnThreshold</a></pre>
+<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.134">logQueueWarnThreshold</a></pre>
</li>
</ul>
<a name="replicationEndpoint">
@@ -674,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.134">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.136">replicationEndpoint</a></pre>
</li>
</ul>
<a name="walEntryFilter">
@@ -683,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.136">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.138">walEntryFilter</a></pre>
</li>
</ul>
<a name="throttler">
@@ -692,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.138">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.140">throttler</a></pre>
</li>
</ul>
<a name="logQueueSize">
@@ -701,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.139">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.141">logQueueSize</a></pre>
</li>
</ul>
<a name="workerThreads">
@@ -710,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.140">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.142">workerThreads</a></pre>
</li>
</ul>
</li>
@@ -727,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.87">ReplicationSource</a>()</pre>
+<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.89">ReplicationSource</a>()</pre>
</li>
</ul>
</li>
@@ -744,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.157">init</a>(org.apache.hadoop.conf.Configuration conf,
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.159">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,
@@ -770,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.192">decorateConf</a>()</pre>
+<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.194">decorateConf</a>()</pre>
</li>
</ul>
<a name="enqueueLog(org.apache.hadoop.fs.Path)">
@@ -779,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.200">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.202">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>
@@ -794,7 +794,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<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.232">addHFileRefs</a>(<a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName,
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.234">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>
@@ -814,7 +814,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/replication/region
<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.259">uninitialize</a>()</pre>
+<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.261">uninitialize</a>()</pre>
</li>
</ul>
<a name="run()">
@@ -823,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.269">run</a>()</pre>
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.271">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>
@@ -838,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.335">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.337">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>
@@ -851,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.353">isPeerEnabled</a>()</pre>
+<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.355">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>
@@ -862,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.358">startup</a>()</pre>
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.360">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>
@@ -877,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.371">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.373">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>
@@ -892,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.376">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.378">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>
@@ -908,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.380">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.382">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>
@@ -919,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.415">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.417">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>
@@ -934,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.420">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.422">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>
@@ -949,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.425">getCurrentPath</a>()</pre>
+<pre>public org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.427">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>
@@ -964,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.433">isSourceActive</a>()</pre>
+<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.435">isSourceActive</a>()</pre>
</li>
</ul>
<a name="getStats()">
@@ -973,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.460">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.462">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>
@@ -989,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.484">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.486">getSourceMetrics</a>()</pre>
<div class="block">Get Replication Source Metrics</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>sourceMetrics</dd></dl>
</li>