http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f68717a0/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html index 2af166b..ae8e435 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html @@ -96,7 +96,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/ReplicationSink.html#line.71">ReplicationSink</a> +public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.77">ReplicationSink</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></pre> <div class="block"><p> This class is responsible for replicating the edits coming @@ -134,13 +134,21 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#conf">conf</a></strong></code> </td> </tr> <tr class="rowColor"> +<td class="colFirst"><code>private long</code></td> +<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#hfilesReplicated">hfilesReplicated</a></strong></code> </td> +</tr> +<tr class="altColor"> <td class="colFirst"><code>private static org.apache.commons.logging.Log</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#LOG">LOG</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSink.html" title="class in org.apache.hadoop.hbase.replication.regionserver">MetricsSink</a></code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#metrics">metrics</a></strong></code> </td> </tr> +<tr class="altColor"> +<td class="colFirst"><code>private <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/SourceFSConfigurationProvider.html" title="interface in org.apache.hadoop.hbase.replication.regionserver">SourceFSConfigurationProvider</a></code></td> +<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#provider">provider</a></strong></code> </td> +</tr> <tr class="rowColor"> <td class="colFirst"><code>private <a href="../../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client">Connection</a></code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#sharedHtableCon">sharedHtableCon</a></strong></code> </td> @@ -189,6 +197,19 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <th class="colLast" scope="col">Method and Description</th> </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/ReplicationSink.html#addFamilyAndItsHFilePathToTableInMap(byte[],%20java.lang.String,%20java.util.List)">addFamilyAndItsHFilePathToTableInMap</a></strong>(byte[] family, + <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> pathToHfileFromNS, + <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/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><byte[],<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>>>> familyHFilePathsList)</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/ReplicationSink.html#addNewTableEntryInMap(java.util.Map,%20byte[],%20java.lang.String,%20java.lang.String)">addNewTableEntryInMap</a></strong>(<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/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><byte[],<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/ja va/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>>>>> bulkLoadHFileMap, + byte[] family, + <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> pathToHfileFromNS, + <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> tableName)</code> </td> +</tr> +<tr class="altColor"> <td class="colFirst"><code>private <K1,K2,V> <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><V></code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#addToHashMultiMap(java.util.Map,%20K1,%20K2,%20V)">addToHashMultiMap</a></strong>(<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><K1,<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><K2,<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><V>>> map, K1 key1, @@ -207,42 +228,62 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? </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/ReplicationSink.html#buildBulkLoadHFileMap(java.util.Map,%20org.apache.hadoop.hbase.TableName,%20org.apache.hadoop.hbase.Cell)">buildBulkLoadHFileMap</a></strong>(<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/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><byte[],<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/j avase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>>>>> bulkLoadHFileMap, + <a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> table, + <a href="../../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> cell)</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/ReplicationSink.html#decorateConf()">decorateConf</a></strong>()</code> <div class="block">decorate the Configuration object to make replication more receptive to delays: lessen the timeout and numTries.</div> </td> </tr> +<tr class="altColor"> +<td class="colFirst"><code>private <a href="../../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client">Connection</a></code></td> +<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#getConnection()">getConnection</a></strong>()</code> </td> +</tr> <tr class="rowColor"> +<td class="colFirst"><code>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></code></td> +<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#getHFilePath(org.apache.hadoop.hbase.TableName,%20org.apache.hadoop.hbase.protobuf.generated.WALProtos.BulkLoadDescriptor,%20java.lang.String,%20byte[])">getHFilePath</a></strong>(<a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> table, + org.apache.hadoop.hbase.protobuf.generated.WALProtos.BulkLoadDescriptor bld, + <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> storeFile, + byte[] family)</code> </td> +</tr> +<tr class="altColor"> <td class="colFirst"><code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSink.html" title="class in org.apache.hadoop.hbase.replication.regionserver">MetricsSink</a></code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#getSinkMetrics()">getSinkMetrics</a></strong>()</code> <div class="block">Get replication Sink Metrics</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#getStats()">getStats</a></strong>()</code> <div class="block">Get a string representation of this sink's metrics</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#isNewRowOrType(org.apache.hadoop.hbase.Cell,%20org.apache.hadoop.hbase.Cell)">isNewRowOrType</a></strong>(<a href="../../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> previousCell, <a href="../../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> cell)</code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#replicateEntries(java.util.List,%20org.apache.hadoop.hbase.CellScanner)">replicateEntries</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/ReplicationSink.html#replicateEntries(java.util.List,%20org.apache.hadoop.hbase.CellScanner,%20java.lang.String,%20java.lang.String,%20java.lang.String)">replicateEntries</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">Replicate this array of entries directly into the local cluster using the native client.</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/ReplicationSink.html#stopReplicationSinkServices()">stopReplicationSinkServices</a></strong>()</code> <div class="block">stop the thread pool executor.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>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></code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#toUUID(org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.UUID)">toUUID</a></strong>(org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.UUID uuid)</code> </td> </tr> @@ -274,7 +315,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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/ReplicationSink.html#line.73">LOG</a></pre> +<pre>private static final org.apache.commons.logging.Log <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.79">LOG</a></pre> </li> </ul> <a name="conf"> @@ -283,7 +324,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>conf</h4> -<pre>private final org.apache.hadoop.conf.Configuration <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.74">conf</a></pre> +<pre>private final org.apache.hadoop.conf.Configuration <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.80">conf</a></pre> </li> </ul> <a name="sharedHtableCon"> @@ -292,7 +333,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>sharedHtableCon</h4> -<pre>private volatile <a href="../../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client">Connection</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.77">sharedHtableCon</a></pre> +<pre>private volatile <a href="../../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client">Connection</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.83">sharedHtableCon</a></pre> </li> </ul> <a name="metrics"> @@ -301,7 +342,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>metrics</h4> -<pre>private final <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSink.html" title="class in org.apache.hadoop.hbase.replication.regionserver">MetricsSink</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.78">metrics</a></pre> +<pre>private final <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSink.html" title="class in org.apache.hadoop.hbase.replication.regionserver">MetricsSink</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.84">metrics</a></pre> </li> </ul> <a name="totalReplicatedEdits"> @@ -310,16 +351,34 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>totalReplicatedEdits</h4> -<pre>private final <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/ReplicationSink.html#line.79">totalReplicatedEdits</a></pre> +<pre>private final <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/ReplicationSink.html#line.85">totalReplicatedEdits</a></pre> </li> </ul> <a name="sharedHtableConLock"> <!-- --> </a> -<ul class="blockListLast"> +<ul class="blockList"> <li class="blockList"> <h4>sharedHtableConLock</h4> -<pre>private final <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> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.80">sharedHtableConLock</a></pre> +<pre>private final <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> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.86">sharedHtableConLock</a></pre> +</li> +</ul> +<a name="hfilesReplicated"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>hfilesReplicated</h4> +<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.88">hfilesReplicated</a></pre> +</li> +</ul> +<a name="provider"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>provider</h4> +<pre>private <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/SourceFSConfigurationProvider.html" title="interface in org.apache.hadoop.hbase.replication.regionserver">SourceFSConfigurationProvider</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.89">provider</a></pre> </li> </ul> </li> @@ -336,7 +395,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>ReplicationSink</h4> -<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.89">ReplicationSink</a>(org.apache.hadoop.conf.Configuration conf, +<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.98">ReplicationSink</a>(org.apache.hadoop.conf.Configuration conf, <a href="../../../../../../org/apache/hadoop/hbase/Stoppable.html" title="interface in org.apache.hadoop.hbase">Stoppable</a> stopper) 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">Create a sink for replication</div> @@ -359,34 +418,88 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>decorateConf</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.100">decorateConf</a>()</pre> +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.121">decorateConf</a>()</pre> <div class="block">decorate the Configuration object to make replication more receptive to delays: lessen the timeout and numTries.</div> </li> </ul> -<a name="replicateEntries(java.util.List, org.apache.hadoop.hbase.CellScanner)"> +<a name="replicateEntries(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>replicateEntries</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.118">replicateEntries</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/ReplicationSink.html#line.144">replicateEntries</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">Replicate this array of entries directly into the local cluster using the native client. Only operates against raw protobuf type saving on a conversion from pb to pojo.</div> -<dl><dt><span class="strong">Parameters:</span></dt><dd><code>entries</code> - </dd><dd><code>cells</code> - </dd> +<dl><dt><span class="strong">Parameters:</span></dt><dd><code>entries</code> - </dd><dd><code>cells</code> - </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</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> - If failed to replicate the data</dd></dl> +</li> +</ul> +<a name="buildBulkLoadHFileMap(java.util.Map, org.apache.hadoop.hbase.TableName, org.apache.hadoop.hbase.Cell)"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>buildBulkLoadHFileMap</h4> +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.234">buildBulkLoadHFileMap</a>(<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/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><byte[],<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>>>>> bulkLoadHFileMap, + <a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> table, + <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="addFamilyAndItsHFilePathToTableInMap(byte[], java.lang.String, java.util.List)"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>addFamilyAndItsHFilePathToTableInMap</h4> +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.276">addFamilyAndItsHFilePathToTableInMap</a>(byte[] family, + <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> pathToHfileFromNS, + <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/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><byte[],<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>>>> familyHFilePathsList)</pre> +</li> +</ul> +<a name="addNewTableEntryInMap(java.util.Map, byte[], java.lang.String, java.lang.String)"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>addNewTableEntryInMap</h4> +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.283">addNewTableEntryInMap</a>(<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/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><byte[],<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>>>>> bulkLoadHFileMap, + byte[] family, + <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> pathToHfileFromNS, + <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> tableName)</pre> +</li> +</ul> +<a name="getHFilePath(org.apache.hadoop.hbase.TableName, org.apache.hadoop.hbase.protobuf.generated.WALProtos.BulkLoadDescriptor, java.lang.String, byte[])"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getHFilePath</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/ReplicationSink.html#line.296">getHFilePath</a>(<a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> table, + org.apache.hadoop.hbase.protobuf.generated.WALProtos.BulkLoadDescriptor bld, + <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> storeFile, + byte[] family)</pre> +</li> +</ul> <a name="isNewRowOrType(org.apache.hadoop.hbase.Cell, org.apache.hadoop.hbase.Cell)"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>isNewRowOrType</h4> -<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.180">isNewRowOrType</a>(<a href="../../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> previousCell, +<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.309">isNewRowOrType</a>(<a href="../../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> previousCell, <a href="../../../../../../org/apache/hadoop/hbase/Cell.html" title="interface in org.apache.hadoop.hbase">Cell</a> cell)</pre> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>previousCell</code> - </dd><dd><code>cell</code> - </dd> <dt><span class="strong">Returns:</span></dt><dd>True if we have crossed over onto a new row or type</dd></dl> @@ -398,7 +511,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>toUUID</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/ReplicationSink.html#line.185">toUUID</a>(org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.UUID uuid)</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/ReplicationSink.html#line.314">toUUID</a>(org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.UUID uuid)</pre> </li> </ul> <a name="addToHashMultiMap(java.util.Map,java.lang.Object,java.lang.Object,java.lang.Object)"> @@ -409,7 +522,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>addToHashMultiMap</h4> -<pre>private <K1,K2,V> <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><V> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.198">addToHashMultiMap</a>(<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><K1,<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><K2,<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><V>>> map, +<pre>private <K1,K2,V> <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><V> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.327">addToHashMultiMap</a>(<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><K1,<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><K2,<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><V>>> map, K1 key1, K2 key2, V value)</pre> @@ -425,7 +538,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>stopReplicationSinkServices</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.216">stopReplicationSinkServices</a>()</pre> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.345">stopReplicationSinkServices</a>()</pre> <div class="block">stop the thread pool executor. It is called when the regionserver is stopped.</div> </li> </ul> @@ -435,7 +548,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>batch</h4> -<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.238">batch</a>(<a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, +<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.367">batch</a>(<a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</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><<a href="../../../../../../org/apache/hadoop/hbase/client/Row.html" title="interface in org.apache.hadoop.hbase.client">Row</a>>> allRows) 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">Do the changes and handle the pool</div> @@ -444,13 +557,25 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <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="getConnection()"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getConnection</h4> +<pre>private <a href="../../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client">Connection</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.387">getConnection</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> +<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="getStats()"> <!-- --> </a> <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/ReplicationSink.html#line.272">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/ReplicationSink.html#line.406">getStats</a>()</pre> <div class="block">Get a string representation of this sink's metrics</div> <dl><dt><span class="strong">Returns:</span></dt><dd>string with the total replicated edits count and the date of the last edit that was applied</dd></dl> @@ -462,7 +587,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>getSinkMetrics</h4> -<pre>public <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSink.html" title="class in org.apache.hadoop.hbase.replication.regionserver">MetricsSink</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.282">getSinkMetrics</a>()</pre> +<pre>public <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSink.html" title="class in org.apache.hadoop.hbase.replication.regionserver">MetricsSink</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.html#line.416">getSinkMetrics</a>()</pre> <div class="block">Get replication Sink Metrics</div> <dl><dt><span class="strong">Returns:</span></dt><dd>MetricsSink</dd></dl> </li>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f68717a0/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 5108339..3137100 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.407">ReplicationSource.LogsComparator</a> +<pre>public static class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.439">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> @@ -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.407">ReplicationSource.LogsComparator</a>()</pre> +<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html#line.439">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.410">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.442">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.420">getTS</a>(org.apache.hadoop.fs.Path p)</pre> +<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html#line.452">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/f68717a0/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 160f875..30734c3 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.455">ReplicationSource.ReplicationSourceWorkerThread</a> +<pre>public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.487">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> @@ -144,46 +144,50 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <th class="colLast" scope="col">Field and Description</th> </tr> <tr class="altColor"> +<td class="colFirst"><code>private long</code></td> +<td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#currentNbHFiles">currentNbHFiles</a></strong></code> </td> +</tr> +<tr class="rowColor"> <td class="colFirst"><code>private int</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#currentNbOperations">currentNbOperations</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private org.apache.hadoop.fs.Path</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#currentPath">currentPath</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private int</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#currentSize">currentSize</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private long</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#lastLoggedPosition">lastLoggedPosition</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>(package private) <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></code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#queue">queue</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private <a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Reader.html" title="interface in org.apache.hadoop.hbase.wal">WAL.Reader</a></code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#reader">reader</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>(package private) <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueInfo.html" title="class in org.apache.hadoop.hbase.replication">ReplicationQueueInfo</a></code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#replicationQueueInfo">replicationQueueInfo</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationWALReaderManager.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationWALReaderManager</a></code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#repLogReader">repLogReader</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>(package private) <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSource</a></code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#source">source</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>(package 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></code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#walGroupId">walGroupId</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#workerRunning">workerRunning</a></strong></code> </td> </tr> @@ -230,73 +234,77 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <th class="colLast" scope="col">Method and Description</th> </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#cleanUpHFileRefs(org.apache.hadoop.hbase.regionserver.wal.WALEdit)">cleanUpHFileRefs</a></strong>(<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.regionserver.wal">WALEdit</a> edit)</code> </td> +</tr> +<tr class="rowColor"> <td class="colFirst"><code>private int</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#countDistinctRowKeys(org.apache.hadoop.hbase.regionserver.wal.WALEdit)">countDistinctRowKeys</a></strong>(<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.regionserver.wal">WALEdit</a> edit)</code> <div class="block">Count the number of different row keys in the given edit because of mini-batching.</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>org.apache.hadoop.fs.Path</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#getCurrentPath()">getCurrentPath</a></strong>()</code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>long</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#getCurrentPosition()">getCurrentPosition</a></strong>()</code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>protected boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#getNextPath()">getNextPath</a></strong>()</code> <div class="block">Poll for the next path</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#isCurrentLogEmpty()">isCurrentLogEmpty</a></strong>()</code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#isWorkerActive()">isWorkerActive</a></strong>()</code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#openReader(int)">openReader</a></strong>(int sleepMultiplier)</code> <div class="block">Open a reader on the current path</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>protected boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#processEndOfFile()">processEndOfFile</a></strong>()</code> <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> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#readAllEntriesToReplicateOrNextFile(boolean,%20java.util.List)">readAllEntriesToReplicateOrNextFile</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">Read all the entries from the current log files and retain those that need to be replicated.</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#run()">run</a></strong>()</code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#setWorkerRunning(boolean)">setWorkerRunning</a></strong>(boolean workerRunning)</code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <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="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><strong><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#startup()">startup</a></strong>()</code> </td> </tr> -<tr class="rowColor"> +<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#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> @@ -336,7 +344,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.456">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.488">source</a></pre> </li> </ul> <a name="walGroupId"> @@ -345,7 +353,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.457">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.489">walGroupId</a></pre> </li> </ul> <a name="queue"> @@ -354,7 +362,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.458">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.490">queue</a></pre> </li> </ul> <a name="replicationQueueInfo"> @@ -363,7 +371,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.459">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.491">replicationQueueInfo</a></pre> </li> </ul> <a name="reader"> @@ -372,7 +380,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.461">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.493">reader</a></pre> </li> </ul> <a name="lastLoggedPosition"> @@ -381,7 +389,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.463">lastLoggedPosition</a></pre> +<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.495">lastLoggedPosition</a></pre> </li> </ul> <a name="currentPath"> @@ -390,7 +398,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.465">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.497">currentPath</a></pre> </li> </ul> <a name="repLogReader"> @@ -399,7 +407,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.467">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.499">repLogReader</a></pre> </li> </ul> <a name="currentNbOperations"> @@ -408,7 +416,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.469">currentNbOperations</a></pre> +<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.501">currentNbOperations</a></pre> </li> </ul> <a name="currentSize"> @@ -417,16 +425,25 @@ 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.471">currentSize</a></pre> +<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.503">currentSize</a></pre> </li> </ul> <a name="workerRunning"> <!-- --> </a> -<ul class="blockListLast"> +<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.473">workerRunning</a></pre> +<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.505">workerRunning</a></pre> +</li> +</ul> +<a name="currentNbHFiles"> +<!-- --> +</a> +<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.507">currentNbHFiles</a></pre> </li> </ul> </li> @@ -443,7 +460,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.475">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.509">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> @@ -463,7 +480,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.485">run</a>()</pre> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.519">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> @@ -478,7 +495,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.646">readAllEntriesToReplicateOrNextFile</a>(boolean currentWALisBeingWrittenTo, +<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.681">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. @@ -489,13 +506,25 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <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="cleanUpHFileRefs(org.apache.hadoop.hbase.regionserver.wal.WALEdit)"> +<!-- --> +</a> +<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.739">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> +</li> +</ul> <a name="getNextPath()"> <!-- --> </a> <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.708">getNextPath</a>()</pre> +<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.765">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> @@ -506,7 +535,7 @@ 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.735">openReader</a>(int sleepMultiplier)</pre> +<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.792">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> @@ -518,7 +547,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <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.842">isCurrentLogEmpty</a>()</pre> +<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.899">isCurrentLogEmpty</a>()</pre> </li> </ul> <a name="countDistinctRowKeys(org.apache.hadoop.hbase.regionserver.wal.WALEdit)"> @@ -527,7 +556,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.853">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.910">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> @@ -540,7 +569,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.871">shipEdits</a>(boolean currentWALisBeingWrittenTo, +<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.945">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) @@ -553,7 +582,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.955">processEndOfFile</a>()</pre> +<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1035">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 @@ -566,7 +595,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.980">startup</a>()</pre> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1060">startup</a>()</pre> </li> </ul> <a name="getCurrentPath()"> @@ -575,7 +604,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.994">getCurrentPath</a>()</pre> +<pre>public org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1074">getCurrentPath</a>()</pre> </li> </ul> <a name="getCurrentPosition()"> @@ -584,7 +613,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.998">getCurrentPosition</a>()</pre> +<pre>public long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1078">getCurrentPosition</a>()</pre> </li> </ul> <a name="isWorkerActive()"> @@ -593,7 +622,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.1002">isWorkerActive</a>()</pre> +<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1082">isWorkerActive</a>()</pre> </li> </ul> <a name="terminate(java.lang.String, java.lang.Exception)"> @@ -602,7 +631,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.1006">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.1086">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> @@ -612,7 +641,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.1019">setWorkerRunning</a>(boolean workerRunning)</pre> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.ReplicationSourceWorkerThread.html#line.1099">setWorkerRunning</a>(boolean workerRunning)</pre> </li> </ul> </li>
