http://git-wip-us.apache.org/repos/asf/hbase-site/blob/bcb555af/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html index 550e16d..92f8ac3 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":18,"i5":6,"i6":6,"i7":6,"i8":6,"i9":6,"i10":6,"i11":6,"i12":6,"i13":18,"i14":18,"i15":6,"i16":18,"i17":6,"i18":6,"i19":6,"i20":6,"i21":6}; +var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":18,"i5":6,"i6":6,"i7":6,"i8":6,"i9":6,"i10":6,"i11":6,"i12":18,"i13":6,"i14":18,"i15":18,"i16":6,"i17":18,"i18":6,"i19":6,"i20":6,"i21":6,"i22":6}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],4:["t3","Abstract Methods"],16:["t5","Default Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -106,7 +106,7 @@ var activeTableTab = "activeTableTab"; <hr> <br> <pre>@InterfaceAudience.Private -public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.43">ReplicationSourceInterface</a></pre> +public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.45">ReplicationSourceInterface</a></pre> <div class="block">Interface that defines a replication source</div> </li> </ul> @@ -194,6 +194,12 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getWALFileLengthProvider--">getWALFileLengthProvider</a></span>()</code> </td> </tr> <tr id="i12" class="altColor"> +<td class="colFirst"><code>default <a href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationStatus.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationStatus</a>></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getWalGroupStatus--">getWalGroupStatus</a></span>()</code> +<div class="block">get the stat of replication for each wal group.</div> +</td> +</tr> +<tr id="i13" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#init-org.apache.hadoop.conf.Configuration-org.apache.hadoop.fs.FileSystem-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager-org.apache.hadoop.hbase.replication.ReplicationQueueStorage-org.apache.hadoop.hbase.replication.ReplicationPeer-org.apache.hadoop.hbase.Server-java.lang.String-java.util.UUID-org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider-org.apache.hadoop.hbase.replication.regionserver.MetricsSource-">init</a></span>(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, @@ -208,49 +214,49 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <div class="block">Initializer for the source</div> </td> </tr> -<tr id="i13" class="rowColor"> +<tr id="i14" class="altColor"> <td class="colFirst"><code>default boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#isPeerEnabled--">isPeerEnabled</a></span>()</code> </td> </tr> -<tr id="i14" class="altColor"> +<tr id="i15" class="rowColor"> <td class="colFirst"><code>default boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#isRecovered--">isRecovered</a></span>()</code> </td> </tr> -<tr id="i15" class="rowColor"> +<tr id="i16" class="altColor"> <td class="colFirst"><code>boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#isSourceActive--">isSourceActive</a></span>()</code> </td> </tr> -<tr id="i16" class="altColor"> +<tr id="i17" class="rowColor"> <td class="colFirst"><code>default boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#isSyncReplication--">isSyncReplication</a></span>()</code> </td> </tr> -<tr id="i17" class="rowColor"> +<tr id="i18" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#postShipEdits-java.util.List-int-">postShipEdits</a></span>(<a href="https://docs.oracle.com/javase/8/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, int batchSize)</code> <div class="block">Call this after the shipper thread ship some entries to peer cluster.</div> </td> </tr> -<tr id="i18" class="altColor"> +<tr id="i19" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#startup--">startup</a></span>()</code> <div class="block">Start the replication</div> </td> </tr> -<tr id="i19" class="rowColor"> +<tr id="i20" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#terminate-java.lang.String-">terminate</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> reason)</code> <div class="block">End the replication</div> </td> </tr> -<tr id="i20" class="altColor"> +<tr id="i21" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#terminate-java.lang.String-java.lang.Exception-">terminate</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> reason, <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a> cause)</code> <div class="block">End the replication</div> </td> </tr> -<tr id="i21" class="rowColor"> +<tr id="i22" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#tryThrottle-int-">tryThrottle</a></span>(int batchSize)</code> <div class="block">Try to throttle when the peer config with a bandwidth</div> @@ -277,7 +283,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>init</h4> -<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.52">init</a>(org.apache.hadoop.conf.Configuration conf, +<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.54">init</a>(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a> manager, <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueStorage.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueueStorage</a> queueStorage, @@ -306,7 +312,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>enqueueLog</h4> -<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.61">enqueueLog</a>(org.apache.hadoop.fs.Path log)</pre> +<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.63">enqueueLog</a>(org.apache.hadoop.fs.Path log)</pre> <div class="block">Add a log to the list of logs to replicate</div> <dl> <dt><span class="paramLabel">Parameters:</span></dt> @@ -320,7 +326,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>addHFileRefs</h4> -<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.71">addHFileRefs</a>(<a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, +<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.73">addHFileRefs</a>(<a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, byte[] family, <a href="https://docs.oracle.com/javase/8/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><org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> pairs) throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> @@ -342,7 +348,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>startup</h4> -<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.77">startup</a>()</pre> +<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.79">startup</a>()</pre> <div class="block">Start the replication</div> </li> </ul> @@ -352,7 +358,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>terminate</h4> -<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.83">terminate</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> reason)</pre> +<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.85">terminate</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> reason)</pre> <div class="block">End the replication</div> <dl> <dt><span class="paramLabel">Parameters:</span></dt> @@ -366,7 +372,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>terminate</h4> -<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.90">terminate</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> reason, +<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.92">terminate</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> reason, <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a> cause)</pre> <div class="block">End the replication</div> <dl> @@ -382,7 +388,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>getCurrentPath</h4> -<pre>org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.96">getCurrentPath</a>()</pre> +<pre>org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.98">getCurrentPath</a>()</pre> <div class="block">Get the current log that's replicated</div> <dl> <dt><span class="returnLabel">Returns:</span></dt> @@ -396,7 +402,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>getQueueId</h4> -<pre><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.103">getQueueId</a>()</pre> +<pre><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.105">getQueueId</a>()</pre> <div class="block">Get the queue id that the source is replicating to</div> <dl> <dt><span class="returnLabel">Returns:</span></dt> @@ -410,7 +416,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>getPeerId</h4> -<pre>default <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.109">getPeerId</a>()</pre> +<pre>default <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.111">getPeerId</a>()</pre> <div class="block">Get the id that the source is replicating to.</div> <dl> <dt><span class="returnLabel">Returns:</span></dt> @@ -424,7 +430,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>getPeer</h4> -<pre><a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeer.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationPeer</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.117">getPeer</a>()</pre> +<pre><a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeer.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationPeer</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.119">getPeer</a>()</pre> <div class="block">Get the replication peer instance.</div> <dl> <dt><span class="returnLabel">Returns:</span></dt> @@ -438,7 +444,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>getStats</h4> -<pre><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.124">getStats</a>()</pre> +<pre><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.126">getStats</a>()</pre> <div class="block">Get a string representation of the current statistics for this source</div> <dl> @@ -453,7 +459,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>isPeerEnabled</h4> -<pre>default boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.129">isPeerEnabled</a>()</pre> +<pre>default boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.131">isPeerEnabled</a>()</pre> <dl> <dt><span class="returnLabel">Returns:</span></dt> <dd>peer enabled or not</dd> @@ -466,7 +472,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>isSyncReplication</h4> -<pre>default boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.136">isSyncReplication</a>()</pre> +<pre>default boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.138">isSyncReplication</a>()</pre> <dl> <dt><span class="returnLabel">Returns:</span></dt> <dd>whether this is sync replication peer.</dd> @@ -479,7 +485,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>isSourceActive</h4> -<pre>boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.142">isSourceActive</a>()</pre> +<pre>boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.144">isSourceActive</a>()</pre> <dl> <dt><span class="returnLabel">Returns:</span></dt> <dd>active or not</dd> @@ -492,7 +498,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>getSourceMetrics</h4> -<pre><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html" title="class in org.apache.hadoop.hbase.replication.regionserver">MetricsSource</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.147">getSourceMetrics</a>()</pre> +<pre><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html" title="class in org.apache.hadoop.hbase.replication.regionserver">MetricsSource</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.149">getSourceMetrics</a>()</pre> <dl> <dt><span class="returnLabel">Returns:</span></dt> <dd>metrics of this replication source</dd> @@ -505,7 +511,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>getReplicationEndpoint</h4> -<pre><a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationEndpoint.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationEndpoint</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.152">getReplicationEndpoint</a>()</pre> +<pre><a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationEndpoint.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationEndpoint</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.154">getReplicationEndpoint</a>()</pre> <dl> <dt><span class="returnLabel">Returns:</span></dt> <dd>the replication endpoint used by this replication source</dd> @@ -518,7 +524,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>getSourceManager</h4> -<pre><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/ReplicationSourceInterface.html#line.157">getSourceManager</a>()</pre> +<pre><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/ReplicationSourceInterface.html#line.159">getSourceManager</a>()</pre> <dl> <dt><span class="returnLabel">Returns:</span></dt> <dd>the replication source manager</dd> @@ -531,7 +537,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>getWALFileLengthProvider</h4> -<pre><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALFileLengthProvider.html" title="interface in org.apache.hadoop.hbase.replication.regionserver">WALFileLengthProvider</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.162">getWALFileLengthProvider</a>()</pre> +<pre><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALFileLengthProvider.html" title="interface in org.apache.hadoop.hbase.replication.regionserver">WALFileLengthProvider</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.164">getWALFileLengthProvider</a>()</pre> <dl> <dt><span class="returnLabel">Returns:</span></dt> <dd>the wal file length provider</dd> @@ -544,7 +550,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>tryThrottle</h4> -<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.169">tryThrottle</a>(int batchSize) +<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.171">tryThrottle</a>(int batchSize) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> <div class="block">Try to throttle when the peer config with a bandwidth</div> <dl> @@ -561,7 +567,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>postShipEdits</h4> -<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.176">postShipEdits</a>(<a href="https://docs.oracle.com/javase/8/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>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.178">postShipEdits</a>(<a href="https://docs.oracle.com/javase/8/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, int batchSize)</pre> <div class="block">Call this after the shipper thread ship some entries to peer cluster.</div> <dl> @@ -577,7 +583,7 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep <ul class="blockList"> <li class="blockList"> <h4>getServerWALsBelongTo</h4> -<pre><a href="../../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.183">getServerWALsBelongTo</a>()</pre> +<pre><a href="../../../../../../org/apache/hadoop/hbase/ServerName.html" title="class in org.apache.hadoop.hbase">ServerName</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.185">getServerWALsBelongTo</a>()</pre> <div class="block">The queue of WALs only belong to one region server. This will return the server name which all WALs belong to.</div> <dl> @@ -586,13 +592,27 @@ public interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/rep </dl> </li> </ul> +<a name="getWalGroupStatus--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getWalGroupStatus</h4> +<pre>default <a href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationStatus.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationStatus</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.191">getWalGroupStatus</a>()</pre> +<div class="block">get the stat of replication for each wal group.</div> +<dl> +<dt><span class="returnLabel">Returns:</span></dt> +<dd>stat of replication</dd> +</dl> +</li> +</ul> <a name="isRecovered--"> <!-- --> </a> <ul class="blockListLast"> <li class="blockList"> <h4>isRecovered</h4> -<pre>default boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.188">isRecovered</a>()</pre> +<pre>default boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#line.198">isRecovered</a>()</pre> <dl> <dt><span class="returnLabel">Returns:</span></dt> <dd>whether this is a replication source for recovery.</dd>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/bcb555af/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html index ea2196f..03a0103 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html @@ -184,9 +184,17 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#currentPosition">currentPosition</a></span></code> </td> </tr> <tr class="rowColor"> +<td class="colFirst"><code>private int</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#DEFAULT_TIMEOUT">DEFAULT_TIMEOUT</a></span></code> </td> +</tr> +<tr class="altColor"> <td class="colFirst"><code>protected <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#entryReader">entryReader</a></span></code> </td> </tr> +<tr class="rowColor"> +<td class="colFirst"><code>private int</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#getEntriesTimeout">getEntriesTimeout</a></span></code> </td> +</tr> <tr class="altColor"> <td class="colFirst"><code>private static org.slf4j.Logger</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#LOG">LOG</a></span></code> </td> @@ -447,12 +455,34 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <a name="maxRetriesMultiplier"> <!-- --> </a> -<ul class="blockListLast"> +<ul class="blockList"> <li class="blockList"> <h4>maxRetriesMultiplier</h4> <pre>protected final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.74">maxRetriesMultiplier</a></pre> </li> </ul> +<a name="DEFAULT_TIMEOUT"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>DEFAULT_TIMEOUT</h4> +<pre>private final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.75">DEFAULT_TIMEOUT</a></pre> +<dl> +<dt><span class="seeLabel">See Also:</span></dt> +<dd><a href="../../../../../../constant-values.html#org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceShipper.DEFAULT_TIMEOUT">Constant Field Values</a></dd> +</dl> +</li> +</ul> +<a name="getEntriesTimeout"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>getEntriesTimeout</h4> +<pre>private final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.76">getEntriesTimeout</a></pre> +</li> +</ul> </li> </ul> <!-- ========= CONSTRUCTOR DETAIL ======== --> @@ -467,7 +497,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockListLast"> <li class="blockList"> <h4>ReplicationSourceShipper</h4> -<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.76">ReplicationSourceShipper</a>(org.apache.hadoop.conf.Configuration conf, +<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.78">ReplicationSourceShipper</a>(org.apache.hadoop.conf.Configuration conf, <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> walGroupId, <a href="https://docs.oracle.com/javase/8/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/regionserver/ReplicationSource.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSource</a> source)</pre> @@ -487,7 +517,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>run</h4> -<pre>public final void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.89">run</a>()</pre> +<pre>public final void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.93">run</a>()</pre> <dl> <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> <dd><code><a href="https://docs.oracle.com/javase/8/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="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true"; title="class or interface in java.lang">Runnable</a></code></dd> @@ -502,7 +532,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>noMoreData</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.122">noMoreData</a>()</pre> +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.132">noMoreData</a>()</pre> </li> </ul> <a name="postFinish--"> @@ -511,7 +541,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>postFinish</h4> -<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.134">postFinish</a>()</pre> +<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.144">postFinish</a>()</pre> </li> </ul> <a name="getBatchEntrySizeExcludeBulkLoad-org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch-"> @@ -520,7 +550,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>getBatchEntrySizeExcludeBulkLoad</h4> -<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.141">getBatchEntrySizeExcludeBulkLoad</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> entryBatch)</pre> +<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.151">getBatchEntrySizeExcludeBulkLoad</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> entryBatch)</pre> <div class="block">get batchEntry size excludes bulk load file sizes. Uses ReplicationSourceWALReader's static method.</div> </li> @@ -531,7 +561,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>shipEdits</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.152">shipEdits</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> entryBatch)</pre> +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.162">shipEdits</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> entryBatch)</pre> <div class="block">Do the shipping logic</div> </li> </ul> @@ -541,7 +571,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>cleanUpHFileRefs</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.232">cleanUpHFileRefs</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a> edit) +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.242">cleanUpHFileRefs</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a> edit) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -555,7 +585,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>updateLogPosition</h4> -<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.256">updateLogPosition</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> batch)</pre> +<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.266">updateLogPosition</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> batch)</pre> </li> </ul> <a name="startup-java.lang.Thread.UncaughtExceptionHandler-"> @@ -564,7 +594,7 @@ extends <a href="https://docs.oracle.com/javase/8/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/ReplicationSourceShipper.html#line.280">startup</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.UncaughtExceptionHandler.html?is-external=true"; title="class or interface in java.lang">Thread.UncaughtExceptionHandler</a> handler)</pre> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.290">startup</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.UncaughtExceptionHandler.html?is-external=true"; title="class or interface in java.lang">Thread.UncaughtExceptionHandler</a> handler)</pre> </li> </ul> <a name="getCurrentPath--"> @@ -573,7 +603,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>getCurrentPath</h4> -<pre>org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.286">getCurrentPath</a>()</pre> +<pre>org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.296">getCurrentPath</a>()</pre> </li> </ul> <a name="getCurrentPosition--"> @@ -582,7 +612,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>getCurrentPosition</h4> -<pre>long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.290">getCurrentPosition</a>()</pre> +<pre>long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.300">getCurrentPosition</a>()</pre> </li> </ul> <a name="setWALReader-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader-"> @@ -591,7 +621,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>setWALReader</h4> -<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.294">setWALReader</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader</a> entryReader)</pre> +<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.304">setWALReader</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html" title="class in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader</a> entryReader)</pre> </li> </ul> <a name="getStartPosition--"> @@ -600,7 +630,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>getStartPosition</h4> -<pre>long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.298">getStartPosition</a>()</pre> +<pre>long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.308">getStartPosition</a>()</pre> </li> </ul> <a name="isActive--"> @@ -609,7 +639,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>isActive</h4> -<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.302">isActive</a>()</pre> +<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.312">isActive</a>()</pre> </li> </ul> <a name="setWorkerState-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceShipper.WorkerState-"> @@ -618,7 +648,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>setWorkerState</h4> -<pre>protected final void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.306">setWorkerState</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html" title="enum in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper.WorkerState</a> state)</pre> +<pre>protected final void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.316">setWorkerState</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html" title="enum in org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper.WorkerState</a> state)</pre> </li> </ul> <a name="stopWorker--"> @@ -627,7 +657,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>stopWorker</h4> -<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.310">stopWorker</a>()</pre> +<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.320">stopWorker</a>()</pre> </li> </ul> <a name="isFinished--"> @@ -636,7 +666,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockListLast"> <li class="blockList"> <h4>isFinished</h4> -<pre>public boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.314">isFinished</a>()</pre> +<pre>public boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html#line.324">isFinished</a>()</pre> </li> </ul> </li> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/bcb555af/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html index 2384450..97295e8 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":9,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":9,"i17":10,"i18":10}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":9,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":9,"i18":10,"i19":10}; var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -50,7 +50,7 @@ var activeTableTab = "activeTableTab"; <div class="subNav"> <ul class="navList"> <li><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALActionListener.html" title="class in org.apache.hadoop.hbase.replication.regionserver"><span class="typeNameLink">Prev Class</span></a></li> -<li><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSyncUp.html" title="class in org.apache.hadoop.hbase.replication.regionserver"><span class="typeNameLink">Next Class</span></a></li> +<li><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationStatus.html" title="class in org.apache.hadoop.hbase.replication.regionserver"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> <li><a href="../../../../../../index.html?org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html" target="_top">Frames</a></li> @@ -124,7 +124,7 @@ var activeTableTab = "activeTableTab"; <br> <pre>@InterfaceAudience.Private @InterfaceStability.Evolving -class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.54">ReplicationSourceWALReader</a> +class <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.55">ReplicationSourceWALReader</a> extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true"; title="class or interface in java.lang">Thread</a></pre> <div class="block">Reads and filters WAL entries, groups the filtered entries into batches, and puts the batches onto a queue</div> @@ -323,36 +323,40 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#isReaderRunning--">isReaderRunning</a></span>()</code> </td> </tr> <tr id="i12" class="altColor"> +<td class="colFirst"><code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#poll-long-">poll</a></span>(long timeout)</code> </td> +</tr> +<tr id="i13" class="rowColor"> <td class="colFirst"><code>protected <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#readWALEntries-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-">readWALEntries</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream)</code> </td> </tr> -<tr id="i13" class="rowColor"> +<tr id="i14" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#run--">run</a></span>()</code> </td> </tr> -<tr id="i14" class="altColor"> +<tr id="i15" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#setReaderRunning-boolean-">setReaderRunning</a></span>(boolean readerRunning)</code> </td> </tr> -<tr id="i15" class="rowColor"> +<tr id="i16" class="altColor"> <td class="colFirst"><code>private int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#sizeOfStoreFilesIncludeBulkLoad-org.apache.hadoop.hbase.wal.WALEdit-">sizeOfStoreFilesIncludeBulkLoad</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a> edit)</code> <div class="block">Calculate the total size of all the store files</div> </td> </tr> -<tr id="i16" class="altColor"> +<tr id="i17" class="rowColor"> <td class="colFirst"><code>protected static boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#switched-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-org.apache.hadoop.fs.Path-">switched</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream, org.apache.hadoop.fs.Path path)</code> </td> </tr> -<tr id="i17" class="rowColor"> +<tr id="i18" class="altColor"> <td class="colFirst"><code><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#take--">take</a></span>()</code> <div class="block">Retrieves the next batch of WAL entries from the queue, waiting up to the specified time for a batch to become available</div> </td> </tr> -<tr id="i18" class="altColor"> +<tr id="i19" class="rowColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#updateBatchStats-org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch-org.apache.hadoop.hbase.wal.WAL.Entry-long-">updateBatchStats</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> batch, <a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry, @@ -393,7 +397,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>LOG</h4> -<pre>private static final org.slf4j.Logger <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.55">LOG</a></pre> +<pre>private static final org.slf4j.Logger <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.56">LOG</a></pre> </li> </ul> <a name="logQueue"> @@ -402,7 +406,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>logQueue</h4> -<pre>private final <a href="https://docs.oracle.com/javase/8/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/ReplicationSourceWALReader.html#line.57">logQueue</a></pre> +<pre>private final <a href="https://docs.oracle.com/javase/8/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/ReplicationSourceWALReader.html#line.58">logQueue</a></pre> </li> </ul> <a name="fs"> @@ -411,7 +415,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>fs</h4> -<pre>private final org.apache.hadoop.fs.FileSystem <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.58">fs</a></pre> +<pre>private final org.apache.hadoop.fs.FileSystem <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.59">fs</a></pre> </li> </ul> <a name="conf"> @@ -420,7 +424,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.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/ReplicationSourceWALReader.html#line.59">conf</a></pre> +<pre>private final org.apache.hadoop.conf.Configuration <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.60">conf</a></pre> </li> </ul> <a name="filter"> @@ -429,7 +433,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>filter</h4> -<pre>private final <a href="../../../../../../org/apache/hadoop/hbase/replication/WALEntryFilter.html" title="interface in org.apache.hadoop.hbase.replication">WALEntryFilter</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.60">filter</a></pre> +<pre>private final <a href="../../../../../../org/apache/hadoop/hbase/replication/WALEntryFilter.html" title="interface in org.apache.hadoop.hbase.replication">WALEntryFilter</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.61">filter</a></pre> </li> </ul> <a name="source"> @@ -438,7 +442,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>source</h4> -<pre>private final <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/ReplicationSourceWALReader.html#line.61">source</a></pre> +<pre>private final <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/ReplicationSourceWALReader.html#line.62">source</a></pre> </li> </ul> <a name="entryBatchQueue"> @@ -447,7 +451,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>entryBatchQueue</h4> -<pre>private final <a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/BlockingQueue.html?is-external=true"; title="class or interface in java.util.concurrent">BlockingQueue</a><<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.63">entryBatchQueue</a></pre> +<pre>private final <a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/BlockingQueue.html?is-external=true"; title="class or interface in java.util.concurrent">BlockingQueue</a><<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.64">entryBatchQueue</a></pre> </li> </ul> <a name="replicationBatchSizeCapacity"> @@ -456,7 +460,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>replicationBatchSizeCapacity</h4> -<pre>private final long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.65">replicationBatchSizeCapacity</a></pre> +<pre>private final long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.66">replicationBatchSizeCapacity</a></pre> </li> </ul> <a name="replicationBatchCountCapacity"> @@ -465,7 +469,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>replicationBatchCountCapacity</h4> -<pre>private final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.67">replicationBatchCountCapacity</a></pre> +<pre>private final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.68">replicationBatchCountCapacity</a></pre> </li> </ul> <a name="currentPosition"> @@ -474,7 +478,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>currentPosition</h4> -<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.69">currentPosition</a></pre> +<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.70">currentPosition</a></pre> </li> </ul> <a name="sleepForRetries"> @@ -483,7 +487,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>sleepForRetries</h4> -<pre>private final long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.70">sleepForRetries</a></pre> +<pre>private final long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.71">sleepForRetries</a></pre> </li> </ul> <a name="maxRetriesMultiplier"> @@ -492,7 +496,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>maxRetriesMultiplier</h4> -<pre>private final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.71">maxRetriesMultiplier</a></pre> +<pre>private final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.72">maxRetriesMultiplier</a></pre> </li> </ul> <a name="eofAutoRecovery"> @@ -501,7 +505,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>eofAutoRecovery</h4> -<pre>private final boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.72">eofAutoRecovery</a></pre> +<pre>private final boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.73">eofAutoRecovery</a></pre> </li> </ul> <a name="isReaderRunning"> @@ -510,7 +514,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>isReaderRunning</h4> -<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.75">isReaderRunning</a></pre> +<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.76">isReaderRunning</a></pre> </li> </ul> <a name="totalBufferUsed"> @@ -519,7 +523,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>totalBufferUsed</h4> -<pre>private <a href="https://docs.oracle.com/javase/8/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/ReplicationSourceWALReader.html#line.77">totalBufferUsed</a></pre> +<pre>private <a href="https://docs.oracle.com/javase/8/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/ReplicationSourceWALReader.html#line.78">totalBufferUsed</a></pre> </li> </ul> <a name="totalBufferQuota"> @@ -528,7 +532,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockListLast"> <li class="blockList"> <h4>totalBufferQuota</h4> -<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.78">totalBufferQuota</a></pre> +<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.79">totalBufferQuota</a></pre> </li> </ul> </li> @@ -545,7 +549,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockListLast"> <li class="blockList"> <h4>ReplicationSourceWALReader</h4> -<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.90">ReplicationSourceWALReader</a>(org.apache.hadoop.fs.FileSystem fs, +<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.91">ReplicationSourceWALReader</a>(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf, <a href="https://docs.oracle.com/javase/8/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> logQueue, long startPosition, @@ -578,7 +582,7 @@ extends <a href="https://docs.oracle.com/javase/8/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/ReplicationSourceWALReader.html#line.122">run</a>()</pre> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.123">run</a>()</pre> <dl> <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> <dd><code><a href="https://docs.oracle.com/javase/8/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="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true"; title="class or interface in java.lang">Runnable</a></code></dd> @@ -593,7 +597,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>addEntryToBatch</h4> -<pre>protected final boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.167">addEntryToBatch</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> batch, +<pre>protected final boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.168">addEntryToBatch</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> batch, <a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</pre> </li> </ul> @@ -603,7 +607,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>switched</h4> -<pre>protected static final boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.183">switched</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream, +<pre>protected static final boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.184">switched</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream, org.apache.hadoop.fs.Path path)</pre> </li> </ul> @@ -613,7 +617,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>readWALEntries</h4> -<pre>protected <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.188">readWALEntries</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream) +<pre>protected <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.189">readWALEntries</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a>, <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> <dl> @@ -629,7 +633,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>handleEmptyWALEntryBatch</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.230">handleEmptyWALEntryBatch</a>() +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.231">handleEmptyWALEntryBatch</a>() throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -643,7 +647,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>handleEofException</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.246">handleEofException</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a> e)</pre> +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.247">handleEofException</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a> e)</pre> </li> </ul> <a name="getCurrentPath--"> @@ -652,7 +656,7 @@ extends <a href="https://docs.oracle.com/javase/8/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/ReplicationSourceWALReader.html#line.261">getCurrentPath</a>()</pre> +<pre>public org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.262">getCurrentPath</a>()</pre> </li> </ul> <a name="checkQuota--"> @@ -661,7 +665,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>checkQuota</h4> -<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.272">checkQuota</a>()</pre> +<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.273">checkQuota</a>()</pre> </li> </ul> <a name="createBatch-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-"> @@ -670,7 +674,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>createBatch</h4> -<pre>protected final <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.281">createBatch</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream)</pre> +<pre>protected final <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.282">createBatch</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream)</pre> </li> </ul> <a name="filterEntry-org.apache.hadoop.hbase.wal.WAL.Entry-"> @@ -679,7 +683,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>filterEntry</h4> -<pre>protected final <a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.285">filterEntry</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</pre> +<pre>protected final <a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.286">filterEntry</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</pre> </li> </ul> <a name="take--"> @@ -688,7 +692,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>take</h4> -<pre>public <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.299">take</a>() +<pre>public <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.300">take</a>() throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> <div class="block">Retrieves the next batch of WAL entries from the queue, waiting up to the specified time for a batch to become available</div> @@ -700,13 +704,27 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html </dl> </li> </ul> +<a name="poll-long-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>poll</h4> +<pre>public <a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.304">poll</a>(long timeout) + throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> +<dl> +<dt><span class="throwsLabel">Throws:</span></dt> +<dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></code></dd> +</dl> +</li> +</ul> <a name="getEntrySizeIncludeBulkLoad-org.apache.hadoop.hbase.wal.WAL.Entry-"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>getEntrySizeIncludeBulkLoad</h4> -<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.303">getEntrySizeIncludeBulkLoad</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</pre> +<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.308">getEntrySizeIncludeBulkLoad</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</pre> </li> </ul> <a name="getEntrySizeExcludeBulkLoad-org.apache.hadoop.hbase.wal.WAL.Entry-"> @@ -715,7 +733,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>getEntrySizeExcludeBulkLoad</h4> -<pre>public static long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.310">getEntrySizeExcludeBulkLoad</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</pre> +<pre>public static long <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.315">getEntrySizeExcludeBulkLoad</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</pre> </li> </ul> <a name="updateBatchStats-org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch-org.apache.hadoop.hbase.wal.WAL.Entry-long-"> @@ -724,7 +742,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>updateBatchStats</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.317">updateBatchStats</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> batch, +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.322">updateBatchStats</a>(<a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.html" title="class in org.apache.hadoop.hbase.replication.regionserver">WALEntryBatch</a> batch, <a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry, long entrySize)</pre> </li> @@ -735,7 +753,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>countDistinctRowKeysAndHFiles</h4> -<pre>private <a href="../../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>,<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.331">countDistinctRowKeysAndHFiles</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a> edit)</pre> +<pre>private <a href="../../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>,<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.336">countDistinctRowKeysAndHFiles</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.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> @@ -752,7 +770,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>sizeOfStoreFilesIncludeBulkLoad</h4> -<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.369">sizeOfStoreFilesIncludeBulkLoad</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a> edit)</pre> +<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.374">sizeOfStoreFilesIncludeBulkLoad</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a> edit)</pre> <div class="block">Calculate the total size of all the store files</div> <dl> <dt><span class="paramLabel">Parameters:</span></dt> @@ -768,7 +786,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>acquireBufferQuota</h4> -<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.399">acquireBufferQuota</a>(long size)</pre> +<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.404">acquireBufferQuota</a>(long size)</pre> <dl> <dt><span class="paramLabel">Parameters:</span></dt> <dd><code>size</code> - delta size for grown buffer</dd> @@ -783,7 +801,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockList"> <li class="blockList"> <h4>isReaderRunning</h4> -<pre>public boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.406">isReaderRunning</a>()</pre> +<pre>public boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.411">isReaderRunning</a>()</pre> <dl> <dt><span class="returnLabel">Returns:</span></dt> <dd>whether the reader thread is running</dd> @@ -796,7 +814,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <ul class="blockListLast"> <li class="blockList"> <h4>setReaderRunning</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.413">setReaderRunning</a>(boolean readerRunning)</pre> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.418">setReaderRunning</a>(boolean readerRunning)</pre> <dl> <dt><span class="paramLabel">Parameters:</span></dt> <dd><code>readerRunning</code> - the readerRunning to set</dd> @@ -832,7 +850,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html <div class="subNav"> <ul class="navList"> <li><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALActionListener.html" title="class in org.apache.hadoop.hbase.replication.regionserver"><span class="typeNameLink">Prev Class</span></a></li> -<li><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSyncUp.html" title="class in org.apache.hadoop.hbase.replication.regionserver"><span class="typeNameLink">Next Class</span></a></li> +<li><a href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationStatus.html" title="class in org.apache.hadoop.hbase.replication.regionserver"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> <li><a href="../../../../../../index.html?org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html" target="_top">Frames</a></li>
