You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by gi...@apache.org on 2017/12/01 15:18:54 UTC
[39/50] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a5c4dca3/devapidocs/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html
----------------------------------------------------------------------
diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html
index a3c2c42..bed230a 100644
--- a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html
+++ b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html
@@ -18,8 +18,8 @@
catch(err) {
}
//-->
-var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10};
-var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
+var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":9,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":9,"i22":9};
+var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
var tableTab = "tableTab";
@@ -119,7 +119,7 @@ var activeTableTab = "activeTableTab";
<hr>
<br>
<pre>@InterfaceAudience.LimitedPrivate(value="Configuration")
-public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.130">AsyncFSWAL</a>
+public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.132">AsyncFSWAL</a>
extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html" title="class in org.apache.hadoop.hbase.regionserver.wal">AbstractFSWAL</a><<a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a>></pre>
<div class="block">An asynchronous implementation of FSWAL.
<p>
@@ -134,7 +134,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
</li>
</ol>
</li>
- <li>In the consumer task(in the EventLoop thread)
+ <li>In the consumer task(executed in a single threaded thread pool)
<ol>
<li>Poll the entry from <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#waitingConsumePayloads"><code>waitingConsumePayloads</code></a> and insert it into
<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#toWriteAppends"><code>toWriteAppends</code></a></li>
@@ -159,25 +159,23 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
FSHLog.<br>
For a normal roll request(for example, we have reached the log roll size):
<ol>
- <li>In the log roller thread, we will set <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#waitingRoll"><code>waitingRoll</code></a> to true and
+ <li>In the log roller thread, we will set <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#waitingRoll-int-"><code>waitingRoll(int)</code></a> to true and
<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#readyForRolling"><code>readyForRolling</code></a> to false, and then wait on <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#readyForRolling"><code>readyForRolling</code></a>(see
<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#waitForSafePoint--"><code>waitForSafePoint()</code></a>).</li>
<li>In the consumer thread, we will stop polling entries from <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#waitingConsumePayloads"><code>waitingConsumePayloads</code></a> if
- <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#waitingRoll"><code>waitingRoll</code></a> is true, and also stop writing the entries in <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#toWriteAppends"><code>toWriteAppends</code></a> out.
+ <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#waitingRoll-int-"><code>waitingRoll(int)</code></a> is true, and also stop writing the entries in <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#toWriteAppends"><code>toWriteAppends</code></a> out.
</li>
<li>If there are unflush data in the writer, sync them.</li>
<li>When all out-going sync request is finished, i.e, the <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#unackedAppends"><code>unackedAppends</code></a> is empty,
signal the <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#readyForRollingCond"><code>readyForRollingCond</code></a>.</li>
<li>Back to the log roller thread, now we can confirm that there are no out-going entries, i.e.,
we reach a safe point. So it is safe to replace old writer with new writer now.</li>
- <li>Set <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#writerBroken"><code>writerBroken</code></a> and <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#waitingRoll"><code>waitingRoll</code></a> to false, cancel log roller exit checker
- if any(see the comments in the <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#syncFailed-java.lang.Throwable-"><code>syncFailed(Throwable)</code></a> method to see why we need a checker
- here).</li>
+ <li>Set <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#writerBroken-int-"><code>writerBroken(int)</code></a> and <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#waitingRoll-int-"><code>waitingRoll(int)</code></a> to false.</li>
<li>Schedule the consumer task.</li>
<li>Schedule a background task to close the old writer.</li>
</ol>
For a broken writer roll request, the only difference is that we can bypass the wait for safe
- point stage. See the comments in the <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#syncFailed-java.lang.Throwable-"><code>syncFailed(Throwable)</code></a> method for more details.</div>
+ point stage.</div>
</li>
</ul>
</div>
@@ -216,17 +214,25 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#ASYNC_WAL_CREATE_MAX_RETRIES">ASYNC_WAL_CREATE_MAX_RETRIES</a></span></code> </td>
</tr>
<tr class="rowColor">
+<td class="colFirst"><code>static <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#ASYNC_WAL_USE_SHARED_EVENT_LOOP">ASYNC_WAL_USE_SHARED_EVENT_LOOP</a></span></code> </td>
+</tr>
+<tr class="altColor">
<td class="colFirst"><code>private long</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#batchSize">batchSize</a></span></code> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code>private <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.hadoop.hbase.shaded.io.netty.channel.Channel></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#channelClass">channelClass</a></span></code> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><code>private <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true" title="class or interface in java.util.concurrent">ExecutorService</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#closeExecutor">closeExecutor</a></span></code> </td>
</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>private <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true" title="class or interface in java.util.concurrent">ExecutorService</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#consumeExecutor">consumeExecutor</a></span></code> </td>
+</tr>
<tr class="altColor">
<td class="colFirst"><code>private <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/Lock.html?is-external=true" title="class or interface in java.util.concurrent.locks">Lock</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#consumeLock">consumeLock</a></span></code> </td>
@@ -248,12 +254,20 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#DEFAULT_ASYNC_WAL_CREATE_MAX_RETRIES">DEFAULT_ASYNC_WAL_CREATE_MAX_RETRIES</a></span></code> </td>
</tr>
<tr class="rowColor">
+<td class="colFirst"><code>static boolean</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#DEFAULT_ASYNC_WAL_USE_SHARED_EVENT_LOOP">DEFAULT_ASYNC_WAL_USE_SHARED_EVENT_LOOP</a></span></code> </td>
+</tr>
+<tr class="altColor">
<td class="colFirst"><code>static long</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#DEFAULT_WAL_BATCH_SIZE">DEFAULT_WAL_BATCH_SIZE</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/regionserver/wal/AsyncFSWAL.html#epochAndState">epochAndState</a></span></code> </td>
+</tr>
<tr class="altColor">
-<td class="colFirst"><code>private org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoop</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#eventLoop">eventLoop</a></span></code> </td>
+<td class="colFirst"><code>private org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoopGroup</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#eventLoopGroup">eventLoopGroup</a></span></code> </td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>private long</code></td>
@@ -280,13 +294,21 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#LOG">LOG</a></span></code> </td>
</tr>
<tr class="rowColor">
+<td class="colFirst"><code>private static int</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#MAX_EPOCH">MAX_EPOCH</a></span></code> </td>
+</tr>
+<tr class="altColor">
<td class="colFirst"><code>private boolean</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#readyForRolling">readyForRolling</a></span></code> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><code>private <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/Condition.html?is-external=true" title="class or interface in java.util.concurrent.locks">Condition</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#readyForRollingCond">readyForRollingCond</a></span></code> </td>
</tr>
+<tr class="altColor">
+<td class="colFirst"><code>private boolean</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#rollRequested">rollRequested</a></span></code> </td>
+</tr>
<tr class="rowColor">
<td class="colFirst"><code>private static <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Comparator.html?is-external=true" title="class or interface in java.util">Comparator</a><<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#SEQ_COMPARATOR">SEQ_COMPARATOR</a></span></code> </td>
@@ -312,17 +334,9 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#waitingConsumePayloadsGatingSequence">waitingConsumePayloadsGatingSequence</a></span></code> </td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><code>private boolean</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#waitingRoll">waitingRoll</a></span></code> </td>
-</tr>
-<tr class="altColor">
<td class="colFirst"><code>static <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#WAL_BATCH_SIZE">WAL_BATCH_SIZE</a></span></code> </td>
</tr>
-<tr class="rowColor">
-<td class="colFirst"><code>private boolean</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#writerBroken">writerBroken</a></span></code> </td>
-</tr>
</table>
<ul class="blockList">
<li class="blockList"><a name="fields.inherited.from.class.org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL">
@@ -345,7 +359,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<th class="colOne" scope="col">Constructor and Description</th>
</tr>
<tr class="altColor">
-<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#AsyncFSWAL-org.apache.hadoop.fs.FileSystem-org.apache.hadoop.fs.Path-java.lang.String-java.lang.String-org.apache.hadoop.conf.Configuration-java.util.List-boolean-java.lang.String-java.lang.String-org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoop-java.lang.Class-">AsyncFSWAL</a></span>(org.apache.hadoop.fs.FileSystem fs,
+<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#AsyncFSWAL-org.apache.hadoop.fs.FileSystem-org.apache.hadoop.fs.Path-java.lang.String-java.lang.String-org.apache.hadoop.conf.Configuration-java.util.List-boolean-java.lang.String-java.lang.String-org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoopGroup-java.lang.Class-">AsyncFSWAL</a></span>(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> logDir,
<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> archiveDir,
@@ -354,7 +368,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
boolean failIfWALExists,
<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> prefix,
<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> suffix,
- org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoop eventLoop,
+ org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoopGroup eventLoopGroup,
<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.hadoop.hbase.shaded.io.netty.channel.Channel> channelClass)</code> </td>
</tr>
</table>
@@ -367,7 +381,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
</a>
<h3>Method Summary</h3>
<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation">
-<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption>
+<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t1" class="tableTab"><span><a href="javascript:show(1);">Static Methods</a></span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption>
<tr>
<th class="colFirst" scope="col">Modifier and Type</th>
<th class="colLast" scope="col">Method and Description</th>
@@ -415,64 +429,77 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#doShutdown--">doShutdown</a></span>()</code> </td>
</tr>
<tr id="i8" class="altColor">
+<td class="colFirst"><code>private static int</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#epoch-int-">epoch</a></span>(int epochAndState)</code> </td>
+</tr>
+<tr id="i9" class="rowColor">
<td class="colFirst"><code>private int</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#finishSync-boolean-">finishSync</a></span>(boolean addSyncTrace)</code> </td>
</tr>
-<tr id="i9" class="rowColor">
+<tr id="i10" class="altColor">
<td class="colFirst"><code>private int</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#finishSyncLowerThanTxid-long-boolean-">finishSyncLowerThanTxid</a></span>(long txid,
boolean addSyncTrace)</code> </td>
</tr>
-<tr id="i10" class="altColor">
+<tr id="i11" class="rowColor">
<td class="colFirst"><code>(package private) int</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#getLogReplication--">getLogReplication</a></span>()</code>
<div class="block">This method gets the datanode replication count for the current WAL.</div>
</td>
</tr>
-<tr id="i11" class="rowColor">
+<tr id="i12" class="altColor">
<td class="colFirst"><code>(package private) org.apache.hadoop.hdfs.protocol.DatanodeInfo[]</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#getPipeline--">getPipeline</a></span>()</code>
<div class="block">This method gets the pipeline for the current WAL.</div>
</td>
</tr>
-<tr id="i12" class="altColor">
+<tr id="i13" class="rowColor">
<td class="colFirst"><code>private boolean</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#shouldScheduleConsumer--">shouldScheduleConsumer</a></span>()</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/regionserver/wal/AsyncFSWAL.html#sync--">sync</a></span>()</code>
<div class="block">Sync what we have in the WAL.</div>
</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/regionserver/wal/AsyncFSWAL.html#sync-long-">sync</a></span>(long txid)</code>
<div class="block">Sync the WAL if the txId was not already sync'd.</div>
</td>
</tr>
-<tr id="i15" class="rowColor">
+<tr id="i16" class="altColor">
<td class="colFirst"><code>private void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#sync-org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter-">sync</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> writer)</code> </td>
</tr>
-<tr id="i16" class="altColor">
+<tr id="i17" class="rowColor">
<td class="colFirst"><code>private void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#syncCompleted-org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter-long-long-">syncCompleted</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> writer,
long processedTxid,
long startTimeNs)</code> </td>
</tr>
-<tr id="i17" class="rowColor">
+<tr id="i18" class="altColor">
<td class="colFirst"><code>private void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#syncFailed-java.lang.Throwable-">syncFailed</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true" title="class or interface in java.lang">Throwable</a> error)</code> </td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#syncFailed-long-java.lang.Throwable-">syncFailed</a></span>(long epochWhenSync,
+ <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true" title="class or interface in java.lang">Throwable</a> error)</code> </td>
</tr>
-<tr id="i18" class="altColor">
+<tr id="i19" class="rowColor">
<td class="colFirst"><code>private boolean</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#trySetReadyForRolling--">trySetReadyForRolling</a></span>()</code> </td>
</tr>
-<tr id="i19" class="rowColor">
+<tr id="i20" class="altColor">
<td class="colFirst"><code>private void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#waitForSafePoint--">waitForSafePoint</a></span>()</code> </td>
</tr>
+<tr id="i21" class="rowColor">
+<td class="colFirst"><code>private static boolean</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#waitingRoll-int-">waitingRoll</a></span>(int epochAndState)</code> </td>
+</tr>
+<tr id="i22" class="altColor">
+<td class="colFirst"><code>private static boolean</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#writerBroken-int-">writerBroken</a></span>(int epochAndState)</code> </td>
+</tr>
</table>
<ul class="blockList">
<li class="blockList"><a name="methods.inherited.from.class.org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL">
@@ -508,7 +535,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<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/regionserver/wal/AsyncFSWAL.html#line.132">LOG</a></pre>
+<pre>private static final org.apache.commons.logging.Log <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.134">LOG</a></pre>
</li>
</ul>
<a name="SEQ_COMPARATOR">
@@ -517,7 +544,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>SEQ_COMPARATOR</h4>
-<pre>private static final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Comparator.html?is-external=true" title="class or interface in java.util">Comparator</a><<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.134">SEQ_COMPARATOR</a></pre>
+<pre>private static final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Comparator.html?is-external=true" title="class or interface in java.util">Comparator</a><<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.136">SEQ_COMPARATOR</a></pre>
</li>
</ul>
<a name="WAL_BATCH_SIZE">
@@ -526,7 +553,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>WAL_BATCH_SIZE</h4>
-<pre>public static final <a href="http://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/regionserver/wal/AsyncFSWAL.html#line.139">WAL_BATCH_SIZE</a></pre>
+<pre>public static final <a href="http://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/regionserver/wal/AsyncFSWAL.html#line.141">WAL_BATCH_SIZE</a></pre>
<dl>
<dt><span class="seeLabel">See Also:</span></dt>
<dd><a href="../../../../../../constant-values.html#org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL.WAL_BATCH_SIZE">Constant Field Values</a></dd>
@@ -539,7 +566,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>DEFAULT_WAL_BATCH_SIZE</h4>
-<pre>public static final long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.140">DEFAULT_WAL_BATCH_SIZE</a></pre>
+<pre>public static final long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.142">DEFAULT_WAL_BATCH_SIZE</a></pre>
<dl>
<dt><span class="seeLabel">See Also:</span></dt>
<dd><a href="../../../../../../constant-values.html#org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL.DEFAULT_WAL_BATCH_SIZE">Constant Field Values</a></dd>
@@ -552,7 +579,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>ASYNC_WAL_CREATE_MAX_RETRIES</h4>
-<pre>public static final <a href="http://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/regionserver/wal/AsyncFSWAL.html#line.142">ASYNC_WAL_CREATE_MAX_RETRIES</a></pre>
+<pre>public static final <a href="http://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/regionserver/wal/AsyncFSWAL.html#line.144">ASYNC_WAL_CREATE_MAX_RETRIES</a></pre>
<dl>
<dt><span class="seeLabel">See Also:</span></dt>
<dd><a href="../../../../../../constant-values.html#org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL.ASYNC_WAL_CREATE_MAX_RETRIES">Constant Field Values</a></dd>
@@ -565,20 +592,55 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>DEFAULT_ASYNC_WAL_CREATE_MAX_RETRIES</h4>
-<pre>public static final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.143">DEFAULT_ASYNC_WAL_CREATE_MAX_RETRIES</a></pre>
+<pre>public static final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.145">DEFAULT_ASYNC_WAL_CREATE_MAX_RETRIES</a></pre>
<dl>
<dt><span class="seeLabel">See Also:</span></dt>
<dd><a href="../../../../../../constant-values.html#org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL.DEFAULT_ASYNC_WAL_CREATE_MAX_RETRIES">Constant Field Values</a></dd>
</dl>
</li>
</ul>
-<a name="eventLoop">
+<a name="ASYNC_WAL_USE_SHARED_EVENT_LOOP">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>ASYNC_WAL_USE_SHARED_EVENT_LOOP</h4>
+<pre>public static final <a href="http://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/regionserver/wal/AsyncFSWAL.html#line.147">ASYNC_WAL_USE_SHARED_EVENT_LOOP</a></pre>
+<dl>
+<dt><span class="seeLabel">See Also:</span></dt>
+<dd><a href="../../../../../../constant-values.html#org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL.ASYNC_WAL_USE_SHARED_EVENT_LOOP">Constant Field Values</a></dd>
+</dl>
+</li>
+</ul>
+<a name="DEFAULT_ASYNC_WAL_USE_SHARED_EVENT_LOOP">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>DEFAULT_ASYNC_WAL_USE_SHARED_EVENT_LOOP</h4>
+<pre>public static final boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.149">DEFAULT_ASYNC_WAL_USE_SHARED_EVENT_LOOP</a></pre>
+<dl>
+<dt><span class="seeLabel">See Also:</span></dt>
+<dd><a href="../../../../../../constant-values.html#org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL.DEFAULT_ASYNC_WAL_USE_SHARED_EVENT_LOOP">Constant Field Values</a></dd>
+</dl>
+</li>
+</ul>
+<a name="eventLoopGroup">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>eventLoopGroup</h4>
+<pre>private final org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoopGroup <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.151">eventLoopGroup</a></pre>
+</li>
+</ul>
+<a name="consumeExecutor">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
-<h4>eventLoop</h4>
-<pre>private final org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoop <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.145">eventLoop</a></pre>
+<h4>consumeExecutor</h4>
+<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true" title="class or interface in java.util.concurrent">ExecutorService</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.153">consumeExecutor</a></pre>
</li>
</ul>
<a name="channelClass">
@@ -587,7 +649,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>channelClass</h4>
-<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.hadoop.hbase.shaded.io.netty.channel.Channel> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.147">channelClass</a></pre>
+<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.hadoop.hbase.shaded.io.netty.channel.Channel> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.155">channelClass</a></pre>
</li>
</ul>
<a name="consumeLock">
@@ -596,7 +658,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>consumeLock</h4>
-<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/Lock.html?is-external=true" title="class or interface in java.util.concurrent.locks">Lock</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.149">consumeLock</a></pre>
+<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/Lock.html?is-external=true" title="class or interface in java.util.concurrent.locks">Lock</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.157">consumeLock</a></pre>
</li>
</ul>
<a name="consumer">
@@ -605,7 +667,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>consumer</h4>
-<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.151">consumer</a></pre>
+<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.159">consumer</a></pre>
</li>
</ul>
<a name="hasConsumerTask">
@@ -614,16 +676,38 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>hasConsumerTask</h4>
-<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/function/Supplier.html?is-external=true" title="class or interface in java.util.function">Supplier</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true" title="class or interface in java.lang">Boolean</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.154">hasConsumerTask</a></pre>
+<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/function/Supplier.html?is-external=true" title="class or interface in java.util.function">Supplier</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true" title="class or interface in java.lang">Boolean</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.162">hasConsumerTask</a></pre>
</li>
</ul>
-<a name="waitingRoll">
+<a name="MAX_EPOCH">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
-<h4>waitingRoll</h4>
-<pre>private volatile boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.157">waitingRoll</a></pre>
+<h4>MAX_EPOCH</h4>
+<pre>private static final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.164">MAX_EPOCH</a></pre>
+<dl>
+<dt><span class="seeLabel">See Also:</span></dt>
+<dd><a href="../../../../../../constant-values.html#org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL.MAX_EPOCH">Constant Field Values</a></dd>
+</dl>
+</li>
+</ul>
+<a name="epochAndState">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>epochAndState</h4>
+<pre>private volatile int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.172">epochAndState</a></pre>
+</li>
+</ul>
+<a name="rollRequested">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>rollRequested</h4>
+<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.175">rollRequested</a></pre>
</li>
</ul>
<a name="readyForRolling">
@@ -632,7 +716,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>readyForRolling</h4>
-<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.159">readyForRolling</a></pre>
+<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.177">readyForRolling</a></pre>
</li>
</ul>
<a name="readyForRollingCond">
@@ -641,7 +725,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>readyForRollingCond</h4>
-<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/Condition.html?is-external=true" title="class or interface in java.util.concurrent.locks">Condition</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.161">readyForRollingCond</a></pre>
+<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/Condition.html?is-external=true" title="class or interface in java.util.concurrent.locks">Condition</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.179">readyForRollingCond</a></pre>
</li>
</ul>
<a name="waitingConsumePayloads">
@@ -650,7 +734,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>waitingConsumePayloads</h4>
-<pre>private final com.lmax.disruptor.RingBuffer<<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/RingBufferTruck.html" title="class in org.apache.hadoop.hbase.regionserver.wal">RingBufferTruck</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.163">waitingConsumePayloads</a></pre>
+<pre>private final com.lmax.disruptor.RingBuffer<<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/RingBufferTruck.html" title="class in org.apache.hadoop.hbase.regionserver.wal">RingBufferTruck</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.181">waitingConsumePayloads</a></pre>
</li>
</ul>
<a name="waitingConsumePayloadsGatingSequence">
@@ -659,7 +743,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>waitingConsumePayloadsGatingSequence</h4>
-<pre>private final com.lmax.disruptor.Sequence <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.165">waitingConsumePayloadsGatingSequence</a></pre>
+<pre>private final com.lmax.disruptor.Sequence <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.183">waitingConsumePayloadsGatingSequence</a></pre>
</li>
</ul>
<a name="consumerScheduled">
@@ -668,16 +752,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>consumerScheduled</h4>
-<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicBoolean.html?is-external=true" title="class or interface in java.util.concurrent.atomic">AtomicBoolean</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.167">consumerScheduled</a></pre>
-</li>
-</ul>
-<a name="writerBroken">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>writerBroken</h4>
-<pre>private volatile boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.170">writerBroken</a></pre>
+<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicBoolean.html?is-external=true" title="class or interface in java.util.concurrent.atomic">AtomicBoolean</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.185">consumerScheduled</a></pre>
</li>
</ul>
<a name="batchSize">
@@ -686,7 +761,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>batchSize</h4>
-<pre>private final long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.172">batchSize</a></pre>
+<pre>private final long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.187">batchSize</a></pre>
</li>
</ul>
<a name="createMaxRetries">
@@ -695,7 +770,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>createMaxRetries</h4>
-<pre>private final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.174">createMaxRetries</a></pre>
+<pre>private final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.189">createMaxRetries</a></pre>
</li>
</ul>
<a name="closeExecutor">
@@ -704,7 +779,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>closeExecutor</h4>
-<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true" title="class or interface in java.util.concurrent">ExecutorService</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.176">closeExecutor</a></pre>
+<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true" title="class or interface in java.util.concurrent">ExecutorService</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.191">closeExecutor</a></pre>
</li>
</ul>
<a name="fsOut">
@@ -713,7 +788,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>fsOut</h4>
-<pre>private volatile <a href="../../../../../../org/apache/hadoop/hbase/io/asyncfs/AsyncFSOutput.html" title="interface in org.apache.hadoop.hbase.io.asyncfs">AsyncFSOutput</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.179">fsOut</a></pre>
+<pre>private volatile <a href="../../../../../../org/apache/hadoop/hbase/io/asyncfs/AsyncFSOutput.html" title="interface in org.apache.hadoop.hbase.io.asyncfs">AsyncFSOutput</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.194">fsOut</a></pre>
</li>
</ul>
<a name="toWriteAppends">
@@ -722,7 +797,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>toWriteAppends</h4>
-<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Deque.html?is-external=true" title="class or interface in java.util">Deque</a><<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSWALEntry.html" title="class in org.apache.hadoop.hbase.regionserver.wal">FSWALEntry</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.181">toWriteAppends</a></pre>
+<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Deque.html?is-external=true" title="class or interface in java.util">Deque</a><<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSWALEntry.html" title="class in org.apache.hadoop.hbase.regionserver.wal">FSWALEntry</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.196">toWriteAppends</a></pre>
</li>
</ul>
<a name="unackedAppends">
@@ -731,7 +806,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>unackedAppends</h4>
-<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Deque.html?is-external=true" title="class or interface in java.util">Deque</a><<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSWALEntry.html" title="class in org.apache.hadoop.hbase.regionserver.wal">FSWALEntry</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.183">unackedAppends</a></pre>
+<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Deque.html?is-external=true" title="class or interface in java.util">Deque</a><<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSWALEntry.html" title="class in org.apache.hadoop.hbase.regionserver.wal">FSWALEntry</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.198">unackedAppends</a></pre>
</li>
</ul>
<a name="syncFutures">
@@ -740,7 +815,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>syncFutures</h4>
-<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true" title="class or interface in java.util">SortedSet</a><<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.185">syncFutures</a></pre>
+<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true" title="class or interface in java.util">SortedSet</a><<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.200">syncFutures</a></pre>
</li>
</ul>
<a name="highestProcessedAppendTxid">
@@ -749,7 +824,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>highestProcessedAppendTxid</h4>
-<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.188">highestProcessedAppendTxid</a></pre>
+<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.203">highestProcessedAppendTxid</a></pre>
</li>
</ul>
<a name="fileLengthAtLastSync">
@@ -758,7 +833,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>fileLengthAtLastSync</h4>
-<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.191">fileLengthAtLastSync</a></pre>
+<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.206">fileLengthAtLastSync</a></pre>
</li>
</ul>
<a name="highestProcessedAppendTxidAtLastSync">
@@ -767,7 +842,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockListLast">
<li class="blockList">
<h4>highestProcessedAppendTxidAtLastSync</h4>
-<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.193">highestProcessedAppendTxidAtLastSync</a></pre>
+<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.208">highestProcessedAppendTxidAtLastSync</a></pre>
</li>
</ul>
</li>
@@ -778,13 +853,13 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<!-- -->
</a>
<h3>Constructor Detail</h3>
-<a name="AsyncFSWAL-org.apache.hadoop.fs.FileSystem-org.apache.hadoop.fs.Path-java.lang.String-java.lang.String-org.apache.hadoop.conf.Configuration-java.util.List-boolean-java.lang.String-java.lang.String-org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoop-java.lang.Class-">
+<a name="AsyncFSWAL-org.apache.hadoop.fs.FileSystem-org.apache.hadoop.fs.Path-java.lang.String-java.lang.String-org.apache.hadoop.conf.Configuration-java.util.List-boolean-java.lang.String-java.lang.String-org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoopGroup-java.lang.Class-">
<!-- -->
</a>
<ul class="blockListLast">
<li class="blockList">
<h4>AsyncFSWAL</h4>
-<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.195">AsyncFSWAL</a>(org.apache.hadoop.fs.FileSystem fs,
+<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.210">AsyncFSWAL</a>(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> logDir,
<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> archiveDir,
@@ -793,7 +868,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
boolean failIfWALExists,
<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> prefix,
<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> suffix,
- org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoop eventLoop,
+ org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoopGroup eventLoopGroup,
<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.hadoop.hbase.shaded.io.netty.channel.Channel> channelClass)
throws <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FailedLogCloseException.html" title="class in org.apache.hadoop.hbase.regionserver.wal">FailedLogCloseException</a>,
<a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true" title="class or interface in java.io">IOException</a></pre>
@@ -812,22 +887,50 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<!-- -->
</a>
<h3>Method Detail</h3>
+<a name="waitingRoll-int-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>waitingRoll</h4>
+<pre>private static boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.260">waitingRoll</a>(int epochAndState)</pre>
+</li>
+</ul>
+<a name="writerBroken-int-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>writerBroken</h4>
+<pre>private static boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.264">writerBroken</a>(int epochAndState)</pre>
+</li>
+</ul>
+<a name="epoch-int-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>epoch</h4>
+<pre>private static int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.268">epoch</a>(int epochAndState)</pre>
+</li>
+</ul>
<a name="trySetReadyForRolling--">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>trySetReadyForRolling</h4>
-<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.237">trySetReadyForRolling</a>()</pre>
+<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.273">trySetReadyForRolling</a>()</pre>
</li>
</ul>
-<a name="syncFailed-java.lang.Throwable-">
+<a name="syncFailed-long-java.lang.Throwable-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>syncFailed</h4>
-<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.260">syncFailed</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true" title="class or interface in java.lang">Throwable</a> error)</pre>
+<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.296">syncFailed</a>(long epochWhenSync,
+ <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true" title="class or interface in java.lang">Throwable</a> error)</pre>
</li>
</ul>
<a name="syncCompleted-org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter-long-long-">
@@ -836,7 +939,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>syncCompleted</h4>
-<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.292">syncCompleted</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> writer,
+<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.329">syncCompleted</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> writer,
long processedTxid,
long startTimeNs)</pre>
</li>
@@ -847,7 +950,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>sync</h4>
-<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.328">sync</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> writer)</pre>
+<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.351">sync</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> writer)</pre>
</li>
</ul>
<a name="addTimeAnnotation-org.apache.hadoop.hbase.regionserver.wal.SyncFuture-java.lang.String-">
@@ -856,7 +959,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>addTimeAnnotation</h4>
-<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.342">addTimeAnnotation</a>(<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a> future,
+<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.366">addTimeAnnotation</a>(<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a> future,
<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> annotation)</pre>
</li>
</ul>
@@ -866,7 +969,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>finishSyncLowerThanTxid</h4>
-<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.348">finishSyncLowerThanTxid</a>(long txid,
+<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.372">finishSyncLowerThanTxid</a>(long txid,
boolean addSyncTrace)</pre>
</li>
</ul>
@@ -876,7 +979,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>finishSync</h4>
-<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.367">finishSync</a>(boolean addSyncTrace)</pre>
+<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.391">finishSync</a>(boolean addSyncTrace)</pre>
</li>
</ul>
<a name="appendAndSync--">
@@ -885,7 +988,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>appendAndSync</h4>
-<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.404">appendAndSync</a>()</pre>
+<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.428">appendAndSync</a>()</pre>
</li>
</ul>
<a name="consume--">
@@ -894,7 +997,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>consume</h4>
-<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.472">consume</a>()</pre>
+<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.480">consume</a>()</pre>
</li>
</ul>
<a name="shouldScheduleConsumer--">
@@ -903,7 +1006,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>shouldScheduleConsumer</h4>
-<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.546">shouldScheduleConsumer</a>()</pre>
+<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.555">shouldScheduleConsumer</a>()</pre>
</li>
</ul>
<a name="append-org.apache.hadoop.hbase.client.RegionInfo-org.apache.hadoop.hbase.wal.WALKey-org.apache.hadoop.hbase.wal.WALEdit-boolean-">
@@ -912,7 +1015,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>append</h4>
-<pre>public long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.554">append</a>(<a href="../../../../../../org/apache/hadoop/hbase/client/RegionInfo.html" title="interface in org.apache.hadoop.hbase.client">RegionInfo</a> hri,
+<pre>public long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.564">append</a>(<a href="../../../../../../org/apache/hadoop/hbase/client/RegionInfo.html" title="interface in org.apache.hadoop.hbase.client">RegionInfo</a> hri,
<a href="../../../../../../org/apache/hadoop/hbase/wal/WALKey.html" title="class in org.apache.hadoop.hbase.wal">WALKey</a> key,
<a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a> edits,
boolean inMemstore)
@@ -955,7 +1058,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>sync</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.565">sync</a>()
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.575">sync</a>()
throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true" title="class or interface in java.io">IOException</a></pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.html#sync--">WAL</a></code></span></div>
<div class="block">Sync what we have in the WAL.</div>
@@ -971,7 +1074,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>sync</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.584">sync</a>(long txid)
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.594">sync</a>(long txid)
throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true" title="class or interface in java.io">IOException</a></pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.html#sync-long-">WAL</a></code></span></div>
<div class="block">Sync the WAL if the txId was not already sync'd.</div>
@@ -989,7 +1092,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>createWriterInstance</h4>
-<pre>protected <a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.607">createWriterInstance</a>(org.apache.hadoop.fs.Path path)
+<pre>protected <a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.617">createWriterInstance</a>(org.apache.hadoop.fs.Path path)
throws <a href="http://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="overrideSpecifyLabel">Specified by:</span></dt>
@@ -1005,7 +1108,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>waitForSafePoint</h4>
-<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.650">waitForSafePoint</a>()</pre>
+<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.660">waitForSafePoint</a>()</pre>
</li>
</ul>
<a name="doReplaceWriter-org.apache.hadoop.fs.Path-org.apache.hadoop.fs.Path-org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter-">
@@ -1014,7 +1117,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>doReplaceWriter</h4>
-<pre>protected long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.669">doReplaceWriter</a>(org.apache.hadoop.fs.Path oldPath,
+<pre>protected long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.680">doReplaceWriter</a>(org.apache.hadoop.fs.Path oldPath,
org.apache.hadoop.fs.Path newPath,
<a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> nextWriter)
throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true" title="class or interface in java.io">IOException</a></pre>
@@ -1034,7 +1137,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>doShutdown</h4>
-<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.704">doShutdown</a>()
+<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.719">doShutdown</a>()
throws <a href="http://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="overrideSpecifyLabel">Specified by:</span></dt>
@@ -1050,7 +1153,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>doAppend</h4>
-<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.716">doAppend</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> writer,
+<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.734">doAppend</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> writer,
<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSWALEntry.html" title="class in org.apache.hadoop.hbase.regionserver.wal">FSWALEntry</a> entry)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
@@ -1064,7 +1167,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockList">
<li class="blockList">
<h4>getPipeline</h4>
-<pre>org.apache.hadoop.hdfs.protocol.DatanodeInfo[] <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.721">getPipeline</a>()</pre>
+<pre>org.apache.hadoop.hdfs.protocol.DatanodeInfo[] <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.739">getPipeline</a>()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getPipeline--">AbstractFSWAL</a></code></span></div>
<div class="block">This method gets the pipeline for the current WAL.</div>
<dl>
@@ -1079,7 +1182,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst
<ul class="blockListLast">
<li class="blockList">
<h4>getLogReplication</h4>
-<pre>int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.727">getLogReplication</a>()</pre>
+<pre>int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line.745">getLogReplication</a>()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getLogReplication--">AbstractFSWAL</a></code></span></div>
<div class="block">This method gets the datanode replication count for the current WAL.</div>
<dl>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a5c4dca3/devapidocs/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html
----------------------------------------------------------------------
diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html
index d736423..adb1af8 100644
--- a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html
+++ b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html
@@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab";
</dl>
<hr>
<br>
-<pre>private static final class <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#line.63">AsyncProtobufLogWriter.OutputStreamWrapper</a>
+<pre>private static final class <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#line.62">AsyncProtobufLogWriter.OutputStreamWrapper</a>
extends <a href="http://docs.oracle.com/javase/8/docs/api/java/io/OutputStream.html?is-external=true" title="class or interface in java.io">OutputStream</a>
implements <a href="../../../../../../org/apache/hadoop/hbase/io/ByteBufferWriter.html" title="interface in org.apache.hadoop.hbase.io">ByteBufferWriter</a></pre>
</li>
@@ -246,7 +246,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/io/ByteBufferWrite
<ul class="blockList">
<li class="blockList">
<h4>out</h4>
-<pre>private final <a href="../../../../../../org/apache/hadoop/hbase/io/asyncfs/AsyncFSOutput.html" title="interface in org.apache.hadoop.hbase.io.asyncfs">AsyncFSOutput</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html#line.66">out</a></pre>
+<pre>private final <a href="../../../../../../org/apache/hadoop/hbase/io/asyncfs/AsyncFSOutput.html" title="interface in org.apache.hadoop.hbase.io.asyncfs">AsyncFSOutput</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html#line.65">out</a></pre>
</li>
</ul>
<a name="oneByteBuf">
@@ -255,7 +255,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/io/ByteBufferWrite
<ul class="blockListLast">
<li class="blockList">
<h4>oneByteBuf</h4>
-<pre>private final byte[] <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html#line.68">oneByteBuf</a></pre>
+<pre>private final byte[] <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html#line.67">oneByteBuf</a></pre>
</li>
</ul>
</li>
@@ -272,7 +272,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/io/ByteBufferWrite
<ul class="blockListLast">
<li class="blockList">
<h4>OutputStreamWrapper</h4>
-<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html#line.76">OutputStreamWrapper</a>(<a href="../../../../../../org/apache/hadoop/hbase/io/asyncfs/AsyncFSOutput.html" title="interface in org.apache.hadoop.hbase.io.asyncfs">AsyncFSOutput</a> out)</pre>
+<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html#line.75">OutputStreamWrapper</a>(<a href="../../../../../../org/apache/hadoop/hbase/io/asyncfs/AsyncFSOutput.html" title="interface in org.apache.hadoop.hbase.io.asyncfs">AsyncFSOutput</a> out)</pre>
</li>
</ul>
</li>
@@ -289,7 +289,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/io/ByteBufferWrite
<ul class="blockList">
<li class="blockList">
<h4>write</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html#line.71">write</a>(int b)
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html#line.70">write</a>(int b)
throws <a href="http://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="overrideSpecifyLabel">Specified by:</span></dt>
@@ -305,7 +305,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/io/ByteBufferWrite
<ul class="blockList">
<li class="blockList">
<h4>write</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html#line.81">write</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true" title="class or interface in java.nio">ByteBuffer</a> b,
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html#line.80">write</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true" title="class or interface in java.nio">ByteBuffer</a> b,
int off,
int len)
throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true" title="class or interface in java.io">IOException</a></pre>
@@ -329,7 +329,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/io/ByteBufferWrite
<ul class="blockList">
<li class="blockList">
<h4>writeInt</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html#line.89">writeInt</a>(int i)
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html#line.88">writeInt</a>(int i)
throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true" title="class or interface in java.io">IOException</a></pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../../org/apache/hadoop/hbase/io/ByteBufferWriter.html#writeInt-int-">ByteBufferWriter</a></code></span></div>
<div class="block">Writes an <code>int</code> to the underlying output stream as four bytes, high byte first.</div>
@@ -349,7 +349,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/io/ByteBufferWrite
<ul class="blockList">
<li class="blockList">
<h4>write</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html#line.94">write</a>(byte[] b,
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html#line.93">write</a>(byte[] b,
int off,
int len)
throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true" title="class or interface in java.io">IOException</a></pre>
@@ -367,7 +367,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/io/ByteBufferWrite
<ul class="blockListLast">
<li class="blockList">
<h4>close</h4>
-<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html#line.99">close</a>()
+<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.OutputStreamWrapper.html#line.98">close</a>()
throws <a href="http://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="overrideSpecifyLabel">Specified by:</span></dt>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a5c4dca3/devapidocs/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html
----------------------------------------------------------------------
diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html
index 9637583..1a8bc32 100644
--- a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html
+++ b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html
@@ -123,7 +123,7 @@ var activeTableTab = "activeTableTab";
<hr>
<br>
<pre>@InterfaceAudience.Private
-public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#line.52">AsyncProtobufLogWriter</a>
+public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#line.51">AsyncProtobufLogWriter</a>
extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractProtobufLogWriter.html" title="class in org.apache.hadoop.hbase.regionserver.wal">AbstractProtobufLogWriter</a>
implements <a href="../../../../../../org/apache/hadoop/hbase/wal/AsyncFSWALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">AsyncFSWALProvider.AsyncWriter</a></pre>
<div class="block">AsyncWriter for protobuf-based WAL.</div>
@@ -173,8 +173,8 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/wal/AsyncFSWALProv
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#channelClass">channelClass</a></span></code> </td>
</tr>
<tr class="altColor">
-<td class="colFirst"><code>private org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoop</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#eventLoop">eventLoop</a></span></code> </td>
+<td class="colFirst"><code>private org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoopGroup</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#eventLoopGroup">eventLoopGroup</a></span></code> </td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>private static org.apache.commons.logging.Log</code></td>
@@ -206,7 +206,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/wal/AsyncFSWALProv
<th class="colOne" scope="col">Constructor and Description</th>
</tr>
<tr class="altColor">
-<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#AsyncProtobufLogWriter-org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoop-java.lang.Class-">AsyncProtobufLogWriter</a></span>(org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoop eventLoop,
+<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#AsyncProtobufLogWriter-org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoopGroup-java.lang.Class-">AsyncProtobufLogWriter</a></span>(org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoopGroup eventLoopGroup,
<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.hadoop.hbase.shaded.io.netty.channel.Channel> channelClass)</code> </td>
</tr>
</table>
@@ -318,16 +318,16 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/wal/AsyncFSWALProv
<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/regionserver/wal/AsyncProtobufLogWriter.html#line.55">LOG</a></pre>
+<pre>private static final org.apache.commons.logging.Log <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#line.54">LOG</a></pre>
</li>
</ul>
-<a name="eventLoop">
+<a name="eventLoopGroup">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
-<h4>eventLoop</h4>
-<pre>private final org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoop <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#line.57">eventLoop</a></pre>
+<h4>eventLoopGroup</h4>
+<pre>private final org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoopGroup <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#line.56">eventLoopGroup</a></pre>
</li>
</ul>
<a name="channelClass">
@@ -336,7 +336,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/wal/AsyncFSWALProv
<ul class="blockList">
<li class="blockList">
<h4>channelClass</h4>
-<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.hadoop.hbase.shaded.io.netty.channel.Channel> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#line.59">channelClass</a></pre>
+<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.hadoop.hbase.shaded.io.netty.channel.Channel> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#line.58">channelClass</a></pre>
</li>
</ul>
<a name="output">
@@ -345,7 +345,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/wal/AsyncFSWALProv
<ul class="blockList">
<li class="blockList">
<h4>output</h4>
-<pre>private <a href="../../../../../../org/apache/hadoop/hbase/io/asyncfs/AsyncFSOutput.html" title="interface in org.apache.hadoop.hbase.io.asyncfs">AsyncFSOutput</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#line.61">output</a></pre>
+<pre>private <a href="../../../../../../org/apache/hadoop/hbase/io/asyncfs/AsyncFSOutput.html" title="interface in org.apache.hadoop.hbase.io.asyncfs">AsyncFSOutput</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#line.60">output</a></pre>
</li>
</ul>
<a name="asyncOutputWrapper">
@@ -354,7 +354,7 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/wal/AsyncFSWALProv
<ul class="blockListLast">
<li class="blockList">
<h4>asyncOutputWrapper</h4>
-<pre>private <a href="http://docs.oracle.com/javase/8/docs/api/java/io/OutputStream.html?is-external=true" title="class or interface in java.io">OutputStream</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#line.104">asyncOutputWrapper</a></pre>
+<pre>private <a href="http://docs.oracle.com/javase/8/docs/api/java/io/OutputStream.html?is-external=true" title="class or interface in java.io">OutputStream</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#line.103">asyncOutputWrapper</a></pre>
</li>
</ul>
</li>
@@ -365,13 +365,13 @@ implements <a href="../../../../../../org/apache/hadoop/hbase/wal/AsyncFSWALProv
<!-- -->
</a>
<h3>Constructor Detail</h3>
-<a name="AsyncProtobufLogWriter-org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoop-java.lang.Class-">
+<a name="AsyncProtobufLogWriter-org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoopGroup-java.lang.Class-">
<!-- -->
</a>
<ul class="blockListLast">
<li class="blockList">
<h4>AsyncProtobufLogWriter</h4>
-<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#line.106">AsyncProtobufLogWriter</a>(org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoop eventLoop,
+<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.html#line.105">AsyncProtobufLogWriter</a>(org.apache.hadoop.hbase.shaded.io.netty.channel.EventLoopGroup eventLoopGroup,
<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.hadoop.hbase.shaded.io.netty.channel.Channel> channelClass)</pre>
</li>
</ul>