http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f68717a0/devapidocs/org/apache/hadoop/hbase/replication/regionserver/Replication.html
----------------------------------------------------------------------
diff --git
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/Replication.html
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/Replication.html
index 0a79b47..0380c56 100644
---
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/Replication.html
+++
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/Replication.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/Replication.html#line.69">Replication</a>
+public class <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.74">Replication</a>
extends <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALActionsListener.Base.html"
title="class in
org.apache.hadoop.hbase.regionserver.wal">WALActionsListener.Base</a>
implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/ReplicationSourceService.html"
title="interface in
org.apache.hadoop.hbase.regionserver">ReplicationSourceService</a>, <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/ReplicationSinkService.html"
title="interface in
org.apache.hadoop.hbase.regionserver">ReplicationSinkService</a></pre>
<div class="block">Gateway to Replication. Used by <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html"
title="class in
org.apache.hadoop.hbase.regionserver"><code>HRegionServer</code></a>.</div>
@@ -166,40 +166,44 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#replication">replication</a></strong></code> </td>
</tr>
<tr class="rowColor">
+<td class="colFirst"><code>private boolean</code></td>
+<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#replicationForBulkLoadData">replicationForBulkLoadData</a></strong></code> </td>
+</tr>
+<tr class="altColor">
<td class="colFirst"><code>private <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationLoad.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationLoad</a></code></td>
<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#replicationLoad">replicationLoad</a></strong></code> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code>private <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a></code></td>
<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#replicationManager">replicationManager</a></strong></code> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code>private <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationPeers</a></code></td>
<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#replicationPeers">replicationPeers</a></strong></code> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code>private <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></td>
<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#replicationQueues">replicationQueues</a></strong></code> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code>private <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSink</a></code></td>
<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#replicationSink">replicationSink</a></strong></code> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code>private <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationTracker.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationTracker</a></code></td>
<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#replicationTracker">replicationTracker</a></strong></code> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code>private <a
href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ScheduledExecutorService.html?is-external=true";
title="class or interface in
java.util.concurrent">ScheduledExecutorService</a></code></td>
<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#scheduleThreadPool">scheduleThreadPool</a></strong></code>
<div class="block">Statistics thread schedule pool</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code>private <a
href="../../../../../../org/apache/hadoop/hbase/Server.html" title="interface
in org.apache.hadoop.hbase">Server</a></code></td>
<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#server">server</a></strong></code> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code>private int</code></td>
<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#statsThreadPeriod">statsThreadPeriod</a></strong></code> </td>
</tr>
@@ -246,29 +250,35 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<th class="colLast" scope="col">Method and Description</th>
</tr>
<tr class="altColor">
+<td class="colFirst"><code>private static void</code></td>
+<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#addHFileRefsToQueue(org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager,%20org.apache.hadoop.hbase.TableName,%20byte[],%20org.apache.hadoop.hbase.protobuf.generated.WALProtos.StoreDescriptor)">addHFileRefsToQueue</a></strong>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a> replicationManager,
+ <a
href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in
org.apache.hadoop.hbase">TableName</a> tableName,
+ byte[] family,
+
org.apache.hadoop.hbase.protobuf.generated.WALProtos.StoreDescriptor s)</code> </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/Replication.html#buildReplicationLoad()">buildReplicationLoad</a></strong>()</code> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code>static void</code></td>
<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#decorateMasterConfiguration(org.apache.hadoop.conf.Configuration)">decorateMasterConfiguration</a></strong>(org.apache.hadoop.conf.Configuration conf)</code>
-<div class="block">This method modifies the master's configuration in order to
inject
- replication-related features</div>
+<div class="block">This method modifies the master's configuration in order to
inject replication-related features</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a></code></td>
<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#getReplicationManager()">getReplicationManager</a></strong>()</code>
<div class="block">Get the replication sources manager</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code><a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALActionsListener.html"
title="interface in
org.apache.hadoop.hbase.regionserver.wal">WALActionsListener</a></code></td>
<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#getWALActionsListener()">getWALActionsListener</a></strong>()</code>
<div class="block">Returns a WALObserver for the service.</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/Replication.html#initialize(org.apache.hadoop.hbase.Server,%20org.apache.hadoop.fs.FileSystem,%20org.apache.hadoop.fs.Path,%20org.apache.hadoop.fs.Path)">initialize</a></strong>(<a
href="../../../../../../org/apache/hadoop/hbase/Server.html" title="interface
in org.apache.hadoop.hbase">Server</a> server,
org.apache.hadoop.fs.FileSystem fs,
@@ -277,10 +287,14 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<div class="block">Initializes the replication service object.</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code>static boolean</code></td>
<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#isReplication(org.apache.hadoop.conf.Configuration)">isReplication</a></strong>(org.apache.hadoop.conf.Configuration c)</code> </td>
</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>static boolean</code></td>
+<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#isReplicationForBulkLoadDataEnabled(org.apache.hadoop.conf.Configuration)">isReplicationForBulkLoadDataEnabled</a></strong>(org.apache.hadoop.conf.Configuration c)</code> </td>
+</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#join()">join</a></strong>()</code>
@@ -309,33 +323,46 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#replicateLogEntries(java.util.List,%20org.apache.hadoop.hbase.CellScanner)">replicateLogEntries</a></strong>(<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><org.apache.hadoop.hbase.protobuf.generated.AdminProtos.WALEntry> entries,
- <a
href="../../../../../../org/apache/hadoop/hbase/CellScanner.html"
title="interface in org.apache.hadoop.hbase">CellScanner</a> cells)</code>
+<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#replicateLogEntries(java.util.List,%20org.apache.hadoop.hbase.CellScanner,%20java.lang.String,%20java.lang.String,%20java.lang.String)">replicateLogEntries</a></strong>(<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><org.apache.hadoop.hbase.protobuf.generated.AdminProtos.WALEntry> entries,
+ <a
href="../../../../../../org/apache/hadoop/hbase/CellScanner.html"
title="interface in org.apache.hadoop.hbase">CellScanner</a> cells,
+ <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> replicationClusterId,
+ <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> sourceBaseNamespaceDirPath,
+ <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> sourceHFileArchiveDirPath)</code>
<div class="block">Carry on the list of log entries down to the sink</div>
</td>
</tr>
<tr class="rowColor">
+<td class="colFirst"><code>private static void</code></td>
+<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#scopeBulkLoadEdits(org.apache.hadoop.hbase.HTableDescriptor,%20org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager,%20java.util.NavigableMap,%20org.apache.hadoop.hbase.TableName,%20org.apache.hadoop.hbase.Cell)">scopeBulkLoadEdits</a></strong>(<a
href="../../../../../../org/apache/hadoop/hbase/HTableDescriptor.html"
title="class in org.apache.hadoop.hbase">HTableDescriptor</a> htd,
+ <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a> replicationManager,
+ <a
href="http://docs.oracle.com/javase/7/docs/api/java/util/NavigableMap.html?is-external=true";
title="class or interface in java.util">NavigableMap</a><byte[],<a
href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true";
title="class or interface in java.lang">Integer</a>> scopes,
+ <a
href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in
org.apache.hadoop.hbase">TableName</a> tableName,
+ <a
href="../../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in
org.apache.hadoop.hbase">Cell</a> cell)</code> </td>
+</tr>
+<tr class="altColor">
<td class="colFirst"><code>static void</code></td>
-<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#scopeWALEdits(org.apache.hadoop.hbase.HTableDescriptor,%20org.apache.hadoop.hbase.wal.WALKey,%20org.apache.hadoop.hbase.regionserver.wal.WALEdit)">scopeWALEdits</a></strong>(<a
href="../../../../../../org/apache/hadoop/hbase/HTableDescriptor.html"
title="class in org.apache.hadoop.hbase">HTableDescriptor</a> htd,
+<td class="colLast"><code><strong><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/Replication.html#scopeWALEdits(org.apache.hadoop.hbase.HTableDescriptor,%20org.apache.hadoop.hbase.wal.WALKey,%20org.apache.hadoop.hbase.regionserver.wal.WALEdit,%20org.apache.hadoop.conf.Configuration,%20org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager)">scopeWALEdits</a></strong>(<a
href="../../../../../../org/apache/hadoop/hbase/HTableDescriptor.html"
title="class in org.apache.hadoop.hbase">HTableDescriptor</a> htd,
<a
href="../../../../../../org/apache/hadoop/hbase/wal/WALKey.html" title="class
in org.apache.hadoop.hbase.wal">WALKey</a> logKey,
- <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALEdit.html"
title="class in
org.apache.hadoop.hbase.regionserver.wal">WALEdit</a> logEdit)</code>
+ <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALEdit.html"
title="class in
org.apache.hadoop.hbase.regionserver.wal">WALEdit</a> logEdit,
+ org.apache.hadoop.conf.Configuration conf,
+ <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a> replicationManager)</code>
<div class="block">Utility method used to set the correct scopes on each log
key.</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/Replication.html#startReplicationService()">startReplicationService</a></strong>()</code>
<div class="block">If replication is enabled and this cluster is a master,
it starts</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/Replication.html#stopReplicationService()">stopReplicationService</a></strong>()</code>
<div class="block">Stops replication service.</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/Replication.html#visitLogEntryBeforeWrite(org.apache.hadoop.hbase.HTableDescriptor,%20org.apache.hadoop.hbase.wal.WALKey,%20org.apache.hadoop.hbase.regionserver.wal.WALEdit)">visitLogEntryBeforeWrite</a></strong>(<a
href="../../../../../../org/apache/hadoop/hbase/HTableDescriptor.html"
title="class in org.apache.hadoop.hbase">HTableDescriptor</a> htd,
<a
href="../../../../../../org/apache/hadoop/hbase/wal/WALKey.html" title="class
in org.apache.hadoop.hbase.wal">WALKey</a> logKey,
@@ -376,7 +403,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<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/Replication.html#line.71">LOG</a></pre>
+<pre>private static final org.apache.commons.logging.Log <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.76">LOG</a></pre>
</li>
</ul>
<a name="replication">
@@ -385,7 +412,16 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>replication</h4>
-<pre>private boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.73">replication</a></pre>
+<pre>private boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.78">replication</a></pre>
+</li>
+</ul>
+<a name="replicationForBulkLoadData">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>replicationForBulkLoadData</h4>
+<pre>private boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.79">replicationForBulkLoadData</a></pre>
</li>
</ul>
<a name="replicationManager">
@@ -394,7 +430,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>replicationManager</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/Replication.html#line.74">replicationManager</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/Replication.html#line.80">replicationManager</a></pre>
</li>
</ul>
<a name="replicationQueues">
@@ -403,7 +439,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<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/Replication.html#line.75">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/Replication.html#line.81">replicationQueues</a></pre>
</li>
</ul>
<a name="replicationPeers">
@@ -412,7 +448,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<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/Replication.html#line.76">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/Replication.html#line.82">replicationPeers</a></pre>
</li>
</ul>
<a name="replicationTracker">
@@ -421,7 +457,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>replicationTracker</h4>
-<pre>private <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationTracker.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationTracker</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.77">replicationTracker</a></pre>
+<pre>private <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationTracker.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationTracker</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.83">replicationTracker</a></pre>
</li>
</ul>
<a name="conf">
@@ -430,7 +466,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<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/Replication.html#line.78">conf</a></pre>
+<pre>private org.apache.hadoop.conf.Configuration <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.84">conf</a></pre>
</li>
</ul>
<a name="replicationSink">
@@ -439,7 +475,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>replicationSink</h4>
-<pre>private <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSink</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.79">replicationSink</a></pre>
+<pre>private <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSink</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.85">replicationSink</a></pre>
</li>
</ul>
<a name="server">
@@ -448,7 +484,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>server</h4>
-<pre>private <a
href="../../../../../../org/apache/hadoop/hbase/Server.html" title="interface
in org.apache.hadoop.hbase">Server</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.81">server</a></pre>
+<pre>private <a
href="../../../../../../org/apache/hadoop/hbase/Server.html" title="interface
in org.apache.hadoop.hbase">Server</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.87">server</a></pre>
</li>
</ul>
<a name="scheduleThreadPool">
@@ -457,7 +493,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>scheduleThreadPool</h4>
-<pre>private <a
href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ScheduledExecutorService.html?is-external=true";
title="class or interface in
java.util.concurrent">ScheduledExecutorService</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.83">scheduleThreadPool</a></pre>
+<pre>private <a
href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ScheduledExecutorService.html?is-external=true";
title="class or interface in
java.util.concurrent">ScheduledExecutorService</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.89">scheduleThreadPool</a></pre>
<div class="block">Statistics thread schedule pool</div>
</li>
</ul>
@@ -467,7 +503,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>statsThreadPeriod</h4>
-<pre>private int <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.84">statsThreadPeriod</a></pre>
+<pre>private int <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.90">statsThreadPeriod</a></pre>
</li>
</ul>
<a name="replicationLoad">
@@ -476,7 +512,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockListLast">
<li class="blockList">
<h4>replicationLoad</h4>
-<pre>private <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationLoad.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationLoad</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.86">replicationLoad</a></pre>
+<pre>private <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationLoad.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationLoad</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.92">replicationLoad</a></pre>
</li>
</ul>
</li>
@@ -493,7 +529,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>Replication</h4>
-<pre>public <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.96">Replication</a>(<a
href="../../../../../../org/apache/hadoop/hbase/Server.html" title="interface
in org.apache.hadoop.hbase">Server</a> server,
+<pre>public <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.101">Replication</a>(<a
href="../../../../../../org/apache/hadoop/hbase/Server.html" title="interface
in org.apache.hadoop.hbase">Server</a> server,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path logDir,
org.apache.hadoop.fs.Path oldLogDir)
@@ -510,7 +546,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockListLast">
<li class="blockList">
<h4>Replication</h4>
-<pre>public <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.104">Replication</a>()</pre>
+<pre>public <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.109">Replication</a>()</pre>
<div class="block">Empty constructor</div>
</li>
</ul>
@@ -528,7 +564,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>initialize</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.107">initialize</a>(<a
href="../../../../../../org/apache/hadoop/hbase/Server.html" title="interface
in org.apache.hadoop.hbase">Server</a> server,
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.112">initialize</a>(<a
href="../../../../../../org/apache/hadoop/hbase/Server.html" title="interface
in org.apache.hadoop.hbase">Server</a> server,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path logDir,
org.apache.hadoop.fs.Path oldLogDir)
@@ -548,18 +584,29 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>isReplication</h4>
-<pre>public static boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.157">isReplication</a>(org.apache.hadoop.conf.Configuration c)</pre>
+<pre>public static boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.171">isReplication</a>(org.apache.hadoop.conf.Configuration c)</pre>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>c</code> -
Configuration to look at</dd>
<dt><span class="strong">Returns:</span></dt><dd>True if replication is
enabled.</dd></dl>
</li>
</ul>
+<a
name="isReplicationForBulkLoadDataEnabled(org.apache.hadoop.conf.Configuration)">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>isReplicationForBulkLoadDataEnabled</h4>
+<pre>public static boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.179">isReplicationForBulkLoadDataEnabled</a>(org.apache.hadoop.conf.Configuration c)</pre>
+<dl><dt><span class="strong">Parameters:</span></dt><dd><code>c</code> -
Configuration to look at</dd>
+<dt><span class="strong">Returns:</span></dt><dd>True if replication for bulk
load data is enabled.</dd></dl>
+</li>
+</ul>
<a name="getWALActionsListener()">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>getWALActionsListener</h4>
-<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALActionsListener.html"
title="interface in
org.apache.hadoop.hbase.regionserver.wal">WALActionsListener</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.164">getWALActionsListener</a>()</pre>
+<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALActionsListener.html"
title="interface in
org.apache.hadoop.hbase.regionserver.wal">WALActionsListener</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.187">getWALActionsListener</a>()</pre>
<div class="block"><strong>Description copied from interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/regionserver/ReplicationSourceService.html#getWALActionsListener()">ReplicationSourceService</a></code></strong></div>
<div class="block">Returns a WALObserver for the service. This is needed to
observe log rolls and log archival events.</div>
@@ -575,7 +622,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>stopReplicationService</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.170">stopReplicationService</a>()</pre>
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.193">stopReplicationService</a>()</pre>
<div class="block">Stops replication service.</div>
<dl>
<dt><strong>Specified by:</strong></dt>
@@ -589,26 +636,31 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>join</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.177">join</a>()</pre>
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.200">join</a>()</pre>
<div class="block">Join with the replication threads</div>
</li>
</ul>
-<a name="replicateLogEntries(java.util.List,
org.apache.hadoop.hbase.CellScanner)">
+<a name="replicateLogEntries(java.util.List,
org.apache.hadoop.hbase.CellScanner, java.lang.String, java.lang.String,
java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>replicateLogEntries</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.195">replicateLogEntries</a>(<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><org.apache.hadoop.hbase.protobuf.generated.AdminProtos.WALEntry> entries,
- <a
href="../../../../../../org/apache/hadoop/hbase/CellScanner.html"
title="interface in org.apache.hadoop.hbase">CellScanner</a> cells)
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.223">replicateLogEntries</a>(<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><org.apache.hadoop.hbase.protobuf.generated.AdminProtos.WALEntry> entries,
+ <a
href="../../../../../../org/apache/hadoop/hbase/CellScanner.html"
title="interface in org.apache.hadoop.hbase">CellScanner</a> cells,
+ <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> replicationClusterId,
+ <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> sourceBaseNamespaceDirPath,
+ <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> sourceHFileArchiveDirPath)
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">Carry on the list of log entries down to the sink</div>
<dl>
<dt><strong>Specified by:</strong></dt>
-<dd><code><a
href="../../../../../../org/apache/hadoop/hbase/regionserver/ReplicationSinkService.html#replicateLogEntries(java.util.List,%20org.apache.hadoop.hbase.CellScanner)">replicateLogEntries</a></code> in
interface <code><a
href="../../../../../../org/apache/hadoop/hbase/regionserver/ReplicationSinkService.html"
title="interface in
org.apache.hadoop.hbase.regionserver">ReplicationSinkService</a></code></dd>
-<dt><span class="strong">Parameters:</span></dt><dd><code>entries</code> -
list of entries to replicate</dd><dd><code>cells</code> - The data -- the cells
-- that <code>entries</code> describes (the entries
- do not contain the Cells we are replicating; they are passed here on the side
in this
- CellScanner).</dd>
+<dd><code><a
href="../../../../../../org/apache/hadoop/hbase/regionserver/ReplicationSinkService.html#replicateLogEntries(java.util.List,%20org.apache.hadoop.hbase.CellScanner,%20java.lang.String,%20java.lang.String,%20java.lang.String)">replicateLogEntries</a></code> in
interface <code><a
href="../../../../../../org/apache/hadoop/hbase/regionserver/ReplicationSinkService.html"
title="interface in
org.apache.hadoop.hbase.regionserver">ReplicationSinkService</a></code></dd>
+<dt><span class="strong">Parameters:</span></dt><dd><code>entries</code> -
list of entries to replicate</dd><dd><code>cells</code> - The data -- the cells
-- that <code>entries</code> describes (the entries do not
+ contain the Cells we are replicating; they are passed here on the
side in this
+ CellScanner).</dd><dd><code>replicationClusterId</code> - Id which
will uniquely identify source cluster FS client
+ configurations in the replication configuration
directory</dd><dd><code>sourceBaseNamespaceDirPath</code> - Path that point to
the source cluster base namespace
+ directory required for replicating
hfiles</dd><dd><code>sourceHFileArchiveDirPath</code> - Path that point to the
source cluster hfile archive directory</dd>
<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>
</li>
@@ -619,7 +671,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>startReplicationService</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.206">startReplicationService</a>()
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.237">startReplicationService</a>()
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">If replication is enabled and this cluster is a master,
it starts</div>
@@ -636,7 +688,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>getReplicationManager</h4>
-<pre>public <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/Replication.html#line.224">getReplicationManager</a>()</pre>
+<pre>public <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/Replication.html#line.255">getReplicationManager</a>()</pre>
<div class="block">Get the replication sources manager</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>the manager if
replication is enabled, else returns false</dd></dl>
</li>
@@ -647,31 +699,71 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>visitLogEntryBeforeWrite</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.229">visitLogEntryBeforeWrite</a>(<a
href="../../../../../../org/apache/hadoop/hbase/HTableDescriptor.html"
title="class in org.apache.hadoop.hbase">HTableDescriptor</a> htd,
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.260">visitLogEntryBeforeWrite</a>(<a
href="../../../../../../org/apache/hadoop/hbase/HTableDescriptor.html"
title="class in org.apache.hadoop.hbase">HTableDescriptor</a> htd,
<a
href="../../../../../../org/apache/hadoop/hbase/wal/WALKey.html" title="class
in org.apache.hadoop.hbase.wal">WALKey</a> logKey,
- <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALEdit.html"
title="class in
org.apache.hadoop.hbase.regionserver.wal">WALEdit</a> logEdit)</pre>
+ <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALEdit.html"
title="class in
org.apache.hadoop.hbase.regionserver.wal">WALEdit</a> logEdit)
+ 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><strong>Specified by:</strong></dt>
<dd><code><a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALActionsListener.html#visitLogEntryBeforeWrite(org.apache.hadoop.hbase.HTableDescriptor,%20org.apache.hadoop.hbase.wal.WALKey,%20org.apache.hadoop.hbase.regionserver.wal.WALEdit)">visitLogEntryBeforeWrite</a></code> in
interface <code><a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALActionsListener.html"
title="interface in
org.apache.hadoop.hbase.regionserver.wal">WALActionsListener</a></code></dd>
<dt><strong>Overrides:</strong></dt>
<dd><code><a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALActionsListener.Base.html#visitLogEntryBeforeWrite(org.apache.hadoop.hbase.HTableDescriptor,%20org.apache.hadoop.hbase.wal.WALKey,%20org.apache.hadoop.hbase.regionserver.wal.WALEdit)">visitLogEntryBeforeWrite</a></code> in
class <code><a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALActionsListener.Base.html"
title="class in
org.apache.hadoop.hbase.regionserver.wal">WALActionsListener.Base</a></code></dd>
-<dd><code>logEdit</code> - TODO: Retire this in favor of <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALActionsListener.html#visitLogEntryBeforeWrite(org.apache.hadoop.hbase.HRegionInfo,%20org.apache.hadoop.hbase.wal.WALKey,%20org.apache.hadoop.hbase.regionserver.wal.WALEdit)"><code>WALActionsListener.visitLogEntryBeforeWrite(HRegionInfo,
WALKey, WALEdit)</code></a>
- It only exists to get scope when replicating. Scope should be in the WALKey
and not need
- us passing in a <code>htd</code>.</dd></dl>
+<dd><code>logEdit</code> - TODO: Retire this in favor of
+ <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALActionsListener.html#visitLogEntryBeforeWrite(org.apache.hadoop.hbase.HRegionInfo,%20org.apache.hadoop.hbase.wal.WALKey,%20org.apache.hadoop.hbase.regionserver.wal.WALEdit)"><code>WALActionsListener.visitLogEntryBeforeWrite(HRegionInfo,
WALKey, WALEdit)</code></a> It only exists to get
+ scope when replicating. Scope should be in the WALKey and not need
us passing in a
+ <code>htd</code>.</dd>
+<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> - If failed to
parse the WALEdit</dd></dl>
</li>
</ul>
-<a name="scopeWALEdits(org.apache.hadoop.hbase.HTableDescriptor,
org.apache.hadoop.hbase.wal.WALKey,
org.apache.hadoop.hbase.regionserver.wal.WALEdit)">
+<a name="scopeWALEdits(org.apache.hadoop.hbase.HTableDescriptor,
org.apache.hadoop.hbase.wal.WALKey,
org.apache.hadoop.hbase.regionserver.wal.WALEdit,
org.apache.hadoop.conf.Configuration,
org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>scopeWALEdits</h4>
-<pre>public static void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.241">scopeWALEdits</a>(<a
href="../../../../../../org/apache/hadoop/hbase/HTableDescriptor.html"
title="class in org.apache.hadoop.hbase">HTableDescriptor</a> htd,
+<pre>public static void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.274">scopeWALEdits</a>(<a
href="../../../../../../org/apache/hadoop/hbase/HTableDescriptor.html"
title="class in org.apache.hadoop.hbase">HTableDescriptor</a> htd,
<a
href="../../../../../../org/apache/hadoop/hbase/wal/WALKey.html" title="class
in org.apache.hadoop.hbase.wal">WALKey</a> logKey,
- <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALEdit.html"
title="class in
org.apache.hadoop.hbase.regionserver.wal">WALEdit</a> logEdit)</pre>
-<div class="block">Utility method used to set the correct scopes on each log
key. Doesn't set a scope on keys
- from compaction WAL edits and if the scope is local.</div>
-<dl><dt><span class="strong">Parameters:</span></dt><dd><code>htd</code> -
Descriptor used to find the scope to use</dd><dd><code>logKey</code> - Key that
may get scoped according to its edits</dd><dd><code>logEdit</code> - Edits used
to lookup the scopes</dd></dl>
+ <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALEdit.html"
title="class in
org.apache.hadoop.hbase.regionserver.wal">WALEdit</a> logEdit,
+ org.apache.hadoop.conf.Configuration conf,
+ <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a> replicationManager)
+ 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">Utility method used to set the correct scopes on each log
key. Doesn't set a scope on keys from
+ compaction WAL edits and if the scope is local.</div>
+<dl><dt><span class="strong">Parameters:</span></dt><dd><code>htd</code> -
Descriptor used to find the scope to use</dd><dd><code>logKey</code> - Key that
may get scoped according to its edits</dd><dd><code>logEdit</code> - Edits used
to lookup the scopes</dd><dd><code>replicationManager</code> - Manager used to
add bulk load events hfile references</dd>
+<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> - If failed to
parse the WALEdit</dd></dl>
+</li>
+</ul>
+<a name="scopeBulkLoadEdits(org.apache.hadoop.hbase.HTableDescriptor,
org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager,
java.util.NavigableMap, org.apache.hadoop.hbase.TableName,
org.apache.hadoop.hbase.Cell)">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>scopeBulkLoadEdits</h4>
+<pre>private static void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.305">scopeBulkLoadEdits</a>(<a
href="../../../../../../org/apache/hadoop/hbase/HTableDescriptor.html"
title="class in org.apache.hadoop.hbase">HTableDescriptor</a> htd,
+ <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a> replicationManager,
+ <a
href="http://docs.oracle.com/javase/7/docs/api/java/util/NavigableMap.html?is-external=true";
title="class or interface in java.util">NavigableMap</a><byte[],<a
href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true";
title="class or interface in java.lang">Integer</a>> scopes,
+ <a
href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in
org.apache.hadoop.hbase">TableName</a> tableName,
+ <a
href="../../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in
org.apache.hadoop.hbase">Cell</a> cell)
+ 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>
+</li>
+</ul>
+<a
name="addHFileRefsToQueue(org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager,
org.apache.hadoop.hbase.TableName, byte[],
org.apache.hadoop.hbase.protobuf.generated.WALProtos.StoreDescriptor)">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>addHFileRefsToQueue</h4>
+<pre>private static void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.329">addHFileRefsToQueue</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a> replicationManager,
+ <a
href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in
org.apache.hadoop.hbase">TableName</a> tableName,
+ byte[] family,
+
org.apache.hadoop.hbase.protobuf.generated.WALProtos.StoreDescriptor s)
+ 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>
</li>
</ul>
<a name="preLogRoll(org.apache.hadoop.fs.Path, org.apache.hadoop.fs.Path)">
@@ -680,7 +772,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>preLogRoll</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.265">preLogRoll</a>(org.apache.hadoop.fs.Path oldPath,
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.340">preLogRoll</a>(org.apache.hadoop.fs.Path oldPath,
org.apache.hadoop.fs.Path newPath)
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"><strong>Description copied from interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALActionsListener.html#preLogRoll(org.apache.hadoop.fs.Path,%20org.apache.hadoop.fs.Path)">WALActionsListener</a></code></strong></div>
@@ -702,7 +794,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>postLogRoll</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.270">postLogRoll</a>(org.apache.hadoop.fs.Path oldPath,
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.345">postLogRoll</a>(org.apache.hadoop.fs.Path oldPath,
org.apache.hadoop.fs.Path newPath)
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"><strong>Description copied from interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALActionsListener.html#postLogRoll(org.apache.hadoop.fs.Path,%20org.apache.hadoop.fs.Path)">WALActionsListener</a></code></strong></div>
@@ -724,9 +816,8 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>decorateMasterConfiguration</h4>
-<pre>public static void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.279">decorateMasterConfiguration</a>(org.apache.hadoop.conf.Configuration conf)</pre>
-<div class="block">This method modifies the master's configuration in order to
inject
- replication-related features</div>
+<pre>public static void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.353">decorateMasterConfiguration</a>(org.apache.hadoop.conf.Configuration conf)</pre>
+<div class="block">This method modifies the master's configuration in order to
inject replication-related features</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>conf</code> -
</dd></dl>
</li>
</ul>
@@ -736,7 +827,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockList">
<li class="blockList">
<h4>refreshAndGetReplicationLoad</h4>
-<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationLoad.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationLoad</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.319">refreshAndGetReplicationLoad</a>()</pre>
+<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationLoad.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationLoad</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.400">refreshAndGetReplicationLoad</a>()</pre>
<div class="block"><strong>Description copied from interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/regionserver/ReplicationService.html#refreshAndGetReplicationLoad()">ReplicationService</a></code></strong></div>
<div class="block">Refresh and Get ReplicationLoad</div>
<dl>
@@ -751,7 +842,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/regionserver/Repli
<ul class="blockListLast">
<li class="blockList">
<h4>buildReplicationLoad</h4>
-<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.328">buildReplicationLoad</a>()</pre>
+<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/Replication.html#line.409">buildReplicationLoad</a>()</pre>
</li>
</ul>
</li>
