| <!DOCTYPE HTML> |
| <html lang="en"> |
| <head> |
| <!-- Generated by javadoc (17) --> |
| <title>AsyncFSWAL (Apache HBase 4.0.0-alpha-1-SNAPSHOT API)</title> |
| <meta name="viewport" content="width=device-width, initial-scale=1"> |
| <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> |
| <meta name="description" content="declaration: package: org.apache.hadoop.hbase.regionserver.wal, class: AsyncFSWAL"> |
| <meta name="generator" content="javadoc/ClassWriterImpl"> |
| <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> |
| <link rel="stylesheet" type="text/css" href="../../../../../../script-dir/jquery-ui.min.css" title="Style"> |
| <link rel="stylesheet" type="text/css" href="../../../../../../jquery-ui.overrides.css" title="Style"> |
| <script type="text/javascript" src="../../../../../../script.js"></script> |
| <script type="text/javascript" src="../../../../../../script-dir/jquery-3.6.1.min.js"></script> |
| <script type="text/javascript" src="../../../../../../script-dir/jquery-ui.min.js"></script> |
| </head> |
| <body class="class-declaration-page"> |
| <script type="text/javascript">var evenRowColor = "even-row-color"; |
| var oddRowColor = "odd-row-color"; |
| var tableTab = "table-tab"; |
| var activeTableTab = "active-table-tab"; |
| var pathtoroot = "../../../../../../"; |
| loadScripts(document, 'script');</script> |
| <noscript> |
| <div>JavaScript is disabled on your browser.</div> |
| </noscript> |
| <div class="flex-box"> |
| <header role="banner" class="flex-header"> |
| <nav role="navigation"> |
| <!-- ========= START OF TOP NAVBAR ======= --> |
| <div class="top-nav" id="navbar-top"> |
| <div class="skip-nav"><a href="#skip-navbar-top" title="Skip navigation links">Skip navigation links</a></div> |
| <ul id="navbar-top-firstrow" class="nav-list" title="Navigation"> |
| <li><a href="../../../../../../index.html">Overview</a></li> |
| <li><a href="package-summary.html">Package</a></li> |
| <li class="nav-bar-cell1-rev">Class</li> |
| <li><a href="class-use/AsyncFSWAL.html">Use</a></li> |
| <li><a href="package-tree.html">Tree</a></li> |
| <li><a href="../../../../../../deprecated-list.html">Deprecated</a></li> |
| <li><a href="../../../../../../index-all.html">Index</a></li> |
| <li><a href="../../../../../../help-doc.html#class">Help</a></li> |
| </ul> |
| </div> |
| <div class="sub-nav"> |
| <div> |
| <ul class="sub-nav-list"> |
| <li>Summary: </li> |
| <li><a href="#nested-class-summary">Nested</a> | </li> |
| <li><a href="#field-summary">Field</a> | </li> |
| <li><a href="#constructor-summary">Constr</a> | </li> |
| <li><a href="#method-summary">Method</a></li> |
| </ul> |
| <ul class="sub-nav-list"> |
| <li>Detail: </li> |
| <li><a href="#field-detail">Field</a> | </li> |
| <li><a href="#constructor-detail">Constr</a> | </li> |
| <li><a href="#method-detail">Method</a></li> |
| </ul> |
| </div> |
| <div class="nav-list-search"><label for="search-input">SEARCH:</label> |
| <input type="text" id="search-input" value="search" disabled="disabled"> |
| <input type="reset" id="reset-button" value="reset" disabled="disabled"> |
| </div> |
| </div> |
| <!-- ========= END OF TOP NAVBAR ========= --> |
| <span class="skip-nav" id="skip-navbar-top"></span></nav> |
| </header> |
| <div class="flex-content"> |
| <main role="main"> |
| <!-- ======== START OF CLASS DATA ======== --> |
| <div class="header"> |
| <div class="sub-title"><span class="package-label-in-type">Package</span> <a href="package-summary.html">org.apache.hadoop.hbase.regionserver.wal</a></div> |
| <h1 title="Class AsyncFSWAL" class="title">Class AsyncFSWAL</h1> |
| </div> |
| <div class="inheritance" title="Inheritance Tree"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html" title="class or interface in java.lang" class="external-link">java.lang.Object</a> |
| <div class="inheritance"><a href="AbstractFSWAL.html" title="class in org.apache.hadoop.hbase.regionserver.wal">org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL</a><<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a>> |
| <div class="inheritance">org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL</div> |
| </div> |
| </div> |
| <section class="class-description" id="class-description"> |
| <dl class="notes"> |
| <dt>All Implemented Interfaces:</dt> |
| <dd><code><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/io/Closeable.html" title="class or interface in java.io" class="external-link">Closeable</a></code>, <code><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/AutoCloseable.html" title="class or interface in java.lang" class="external-link">AutoCloseable</a></code>, <code><a href="../../replication/regionserver/WALFileLengthProvider.html" title="interface in org.apache.hadoop.hbase.replication.regionserver">WALFileLengthProvider</a></code>, <code><a href="../../wal/WAL.html" title="interface in org.apache.hadoop.hbase.wal">WAL</a></code></dd> |
| </dl> |
| <hr> |
| <div class="type-signature"><span class="annotations">@LimitedPrivate("Configuration") |
| </span><span class="modifiers">public class </span><span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-100">AsyncFSWAL</a></span> |
| <span class="extends-implements">extends <a href="AbstractFSWAL.html" title="class in org.apache.hadoop.hbase.regionserver.wal">AbstractFSWAL</a><<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a>></span></div> |
| <div class="block">An asynchronous implementation of FSWAL. |
| <p> |
| Here 'waitingConsumePayloads' acts as the RingBuffer in FSHLog. |
| <p> |
| For append, we process it as follow: |
| <ol> |
| <li>In the caller thread(typically, in the rpc handler thread): |
| <ol> |
| <li>Insert the entry into 'waitingConsumePayloads'. Use ringbuffer sequence as txid.</li> |
| <li>Schedule the consumer task if needed. See <a href="AbstractFSWAL.html#shouldScheduleConsumer()"><code>AbstractFSWAL.shouldScheduleConsumer()</code></a> for more details. |
| </li> |
| </ol> |
| </li> |
| <li>In the consumer task(executed in a single threaded thread pool) |
| <ol> |
| <li>Poll the entry from <a href="AbstractFSWAL.html#waitingConsumePayloads"><code>AbstractFSWAL.waitingConsumePayloads</code></a> and insert it into |
| <a href="AbstractFSWAL.html#toWriteAppends"><code>AbstractFSWAL.toWriteAppends</code></a></li> |
| <li>Poll the entry from <a href="AbstractFSWAL.html#toWriteAppends"><code>AbstractFSWAL.toWriteAppends</code></a>, append it to the AsyncWriter, and insert it into |
| <a href="AbstractFSWAL.html#unackedAppends"><code>AbstractFSWAL.unackedAppends</code></a></li> |
| <li>If the buffered size reaches <a href="AbstractFSWAL.html#batchSize"><code>AbstractFSWAL.batchSize</code></a>, or there is a sync request, then we call |
| sync on the AsyncWriter.</li> |
| <li>In the callback methods: |
| <ul> |
| <li>If succeeded, poll the entry from <a href="AbstractFSWAL.html#unackedAppends"><code>AbstractFSWAL.unackedAppends</code></a> and drop it.</li> |
| <li>If failed, add all the entries in <a href="AbstractFSWAL.html#unackedAppends"><code>AbstractFSWAL.unackedAppends</code></a> back to <a href="AbstractFSWAL.html#toWriteAppends"><code>AbstractFSWAL.toWriteAppends</code></a> and |
| wait for writing them again.</li> |
| </ul> |
| </li> |
| </ol> |
| </li> |
| </ol> |
| For sync, the processing stages are almost same. And different from FSHLog, we will open a new |
| writer and rewrite unacked entries to the new writer and sync again if we hit a sync error. |
| <p> |
| Here we only describe the logic of doReplaceWriter. The main logic of rollWriter is same with |
| 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="AbstractFSWAL.html#waitingRoll(int)"><code>AbstractFSWAL.waitingRoll(int)</code></a> to true and |
| <a href="AbstractFSWAL.html#readyForRolling"><code>AbstractFSWAL.readyForRolling</code></a> to false, and then wait on <a href="AbstractFSWAL.html#readyForRolling"><code>AbstractFSWAL.readyForRolling</code></a>(see |
| <a href="AbstractFSWAL.html#waitForSafePoint()"><code>AbstractFSWAL.waitForSafePoint()</code></a>).</li> |
| <li>In the consumer thread, we will stop polling entries from <a href="AbstractFSWAL.html#waitingConsumePayloads"><code>AbstractFSWAL.waitingConsumePayloads</code></a> if |
| <a href="AbstractFSWAL.html#waitingRoll(int)"><code>AbstractFSWAL.waitingRoll(int)</code></a> is true, and also stop writing the entries in <a href="AbstractFSWAL.html#toWriteAppends"><code>AbstractFSWAL.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="AbstractFSWAL.html#unackedAppends"><code>AbstractFSWAL.unackedAppends</code></a> is empty, |
| signal the <a href="AbstractFSWAL.html#readyForRollingCond"><code>AbstractFSWAL.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="AbstractFSWAL.html#writerBroken(int)"><code>AbstractFSWAL.writerBroken(int)</code></a> and <a href="AbstractFSWAL.html#waitingRoll(int)"><code>AbstractFSWAL.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.</div> |
| </section> |
| <section class="summary"> |
| <ul class="summary-list"> |
| <!-- ======== NESTED CLASS SUMMARY ======== --> |
| <li> |
| <section class="nested-class-summary" id="nested-class-summary"> |
| <h2>Nested Class Summary</h2> |
| <div class="inherited-list"> |
| <h2 id="nested-classes-inherited-from-class-org.apache.hadoop.hbase.wal.WAL">Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.wal.<a href="../../wal/WAL.html" title="interface in org.apache.hadoop.hbase.wal">WAL</a></h2> |
| <code><a href="../../wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a></code></div> |
| </section> |
| </li> |
| <!-- =========== FIELD SUMMARY =========== --> |
| <li> |
| <section class="field-summary" id="field-summary"> |
| <h2>Field Summary</h2> |
| <div class="caption"><span>Fields</span></div> |
| <div class="summary-table three-column-summary"> |
| <div class="table-header col-first">Modifier and Type</div> |
| <div class="table-header col-second">Field</div> |
| <div class="table-header col-last">Description</div> |
| <div class="col-first even-row-color"><code>static final <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a></code></div> |
| <div class="col-second even-row-color"><code><a href="#ASYNC_WAL_USE_SHARED_EVENT_LOOP" class="member-name-link">ASYNC_WAL_USE_SHARED_EVENT_LOOP</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>static final <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a></code></div> |
| <div class="col-second odd-row-color"><code><a href="#ASYNC_WAL_WAIT_ON_SHUTDOWN_IN_SECONDS" class="member-name-link">ASYNC_WAL_WAIT_ON_SHUTDOWN_IN_SECONDS</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>private final <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Class.html" title="class or interface in java.lang" class="external-link">Class</a><? extends org.apache.hbase.thirdparty.io.netty.channel.Channel></code></div> |
| <div class="col-second even-row-color"><code><a href="#channelClass" class="member-name-link">channelClass</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>static final boolean</code></div> |
| <div class="col-second odd-row-color"><code><a href="#DEFAULT_ASYNC_WAL_USE_SHARED_EVENT_LOOP" class="member-name-link">DEFAULT_ASYNC_WAL_USE_SHARED_EVENT_LOOP</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>static final int</code></div> |
| <div class="col-second even-row-color"><code><a href="#DEFAULT_ASYNC_WAL_WAIT_ON_SHUTDOWN_IN_SECONDS" class="member-name-link">DEFAULT_ASYNC_WAL_WAIT_ON_SHUTDOWN_IN_SECONDS</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>static final long</code></div> |
| <div class="col-second odd-row-color"><code><a href="#DEFAULT_WAL_BATCH_SIZE" class="member-name-link">DEFAULT_WAL_BATCH_SIZE</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>private final org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup</code></div> |
| <div class="col-second even-row-color"><code><a href="#eventLoopGroup" class="member-name-link">eventLoopGroup</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>private <a href="../../io/asyncfs/AsyncFSOutput.html" title="interface in org.apache.hadoop.hbase.io.asyncfs">AsyncFSOutput</a></code></div> |
| <div class="col-second odd-row-color"><code><a href="#fsOut" class="member-name-link">fsOut</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>private static final org.slf4j.Logger</code></div> |
| <div class="col-second even-row-color"><code><a href="#LOG" class="member-name-link">LOG</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>private final <a href="../../io/asyncfs/monitor/StreamSlowMonitor.html" title="class in org.apache.hadoop.hbase.io.asyncfs.monitor">StreamSlowMonitor</a></code></div> |
| <div class="col-second odd-row-color"><code><a href="#streamSlowMonitor" class="member-name-link">streamSlowMonitor</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>static final <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a></code></div> |
| <div class="col-second even-row-color"><code><a href="#WAL_BATCH_SIZE" class="member-name-link">WAL_BATCH_SIZE</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| </div> |
| <div class="inherited-list"> |
| <h3 id="fields-inherited-from-class-org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL">Fields inherited from class org.apache.hadoop.hbase.regionserver.wal.<a href="AbstractFSWAL.html" title="class in org.apache.hadoop.hbase.regionserver.wal">AbstractFSWAL</a></h3> |
| <code><a href="AbstractFSWAL.html#abortable">abortable</a>, <a href="AbstractFSWAL.html#blocksize">blocksize</a>, <a href="AbstractFSWAL.html#closed">closed</a>, <a href="AbstractFSWAL.html#closeExecutor">closeExecutor</a>, <a href="AbstractFSWAL.html#conf">conf</a>, <a href="AbstractFSWAL.html#consumeExecutor">consumeExecutor</a>, <a href="AbstractFSWAL.html#consumer">consumer</a>, <a href="AbstractFSWAL.html#coprocessorHost">coprocessorHost</a>, <a href="AbstractFSWAL.html#DEFAULT_ROLL_ON_SYNC_TIME_MS">DEFAULT_ROLL_ON_SYNC_TIME_MS</a>, <a href="AbstractFSWAL.html#DEFAULT_SLOW_SYNC_ROLL_INTERVAL_MS">DEFAULT_SLOW_SYNC_ROLL_INTERVAL_MS</a>, <a href="AbstractFSWAL.html#DEFAULT_SLOW_SYNC_ROLL_THRESHOLD">DEFAULT_SLOW_SYNC_ROLL_THRESHOLD</a>, <a href="AbstractFSWAL.html#DEFAULT_SLOW_SYNC_TIME_MS">DEFAULT_SLOW_SYNC_TIME_MS</a>, <a href="AbstractFSWAL.html#DEFAULT_WAL_SHUTDOWN_WAIT_TIMEOUT_MS">DEFAULT_WAL_SHUTDOWN_WAIT_TIMEOUT_MS</a>, <a href="AbstractFSWAL.html#DEFAULT_WAL_SYNC_TIMEOUT_MS">DEFAULT_WAL_SYNC_TIMEOUT_MS</a>, <a href="AbstractFSWAL.html#filenum">filenum</a>, <a href="AbstractFSWAL.html#fs">fs</a>, <a href="AbstractFSWAL.html#hasConsumerTask">hasConsumerTask</a>, <a href="AbstractFSWAL.html#highestProcessedAppendTxid">highestProcessedAppendTxid</a>, <a href="AbstractFSWAL.html#highestSyncedTxid">highestSyncedTxid</a>, <a href="AbstractFSWAL.html#highestUnsyncedTxid">highestUnsyncedTxid</a>, <a href="AbstractFSWAL.html#implClassName">implClassName</a>, <a href="AbstractFSWAL.html#inflightWALClosures">inflightWALClosures</a>, <a href="AbstractFSWAL.html#listeners">listeners</a>, <a href="AbstractFSWAL.html#LOG_NAME_COMPARATOR">LOG_NAME_COMPARATOR</a>, <a href="AbstractFSWAL.html#logrollsize">logrollsize</a>, <a href="AbstractFSWAL.html#MAX_LOGS">MAX_LOGS</a>, <a href="AbstractFSWAL.html#maxLogs">maxLogs</a>, <a href="AbstractFSWAL.html#numEntries">numEntries</a>, <a href="AbstractFSWAL.html#ourFiles">ourFiles</a>, <a href="AbstractFSWAL.html#prefixPathStr">prefixPathStr</a>, <a href="AbstractFSWAL.html#RING_BUFFER_SLOT_COUNT">RING_BUFFER_SLOT_COUNT</a>, <a href="AbstractFSWAL.html#ROLL_ON_SYNC_TIME_MS">ROLL_ON_SYNC_TIME_MS</a>, <a href="AbstractFSWAL.html#rollOnSyncNs">rollOnSyncNs</a>, <a href="AbstractFSWAL.html#rollRequested">rollRequested</a>, <a href="AbstractFSWAL.html#rollWriterLock">rollWriterLock</a>, <a href="AbstractFSWAL.html#sequenceIdAccounting">sequenceIdAccounting</a>, <a href="AbstractFSWAL.html#shouldShutDownConsumeExecutorWhenClose">shouldShutDownConsumeExecutorWhenClose</a>, <a href="AbstractFSWAL.html#shutdown">shutdown</a>, <a href="AbstractFSWAL.html#SLOW_SYNC_ROLL_INTERVAL_MS">SLOW_SYNC_ROLL_INTERVAL_MS</a>, <a href="AbstractFSWAL.html#SLOW_SYNC_ROLL_THRESHOLD">SLOW_SYNC_ROLL_THRESHOLD</a>, <a href="AbstractFSWAL.html#SLOW_SYNC_TIME_MS">SLOW_SYNC_TIME_MS</a>, <a href="AbstractFSWAL.html#slowSyncCheckInterval">slowSyncCheckInterval</a>, <a href="AbstractFSWAL.html#slowSyncCount">slowSyncCount</a>, <a href="AbstractFSWAL.html#slowSyncNs">slowSyncNs</a>, <a href="AbstractFSWAL.html#slowSyncRollThreshold">slowSyncRollThreshold</a>, <a href="AbstractFSWAL.html#syncFutureCache">syncFutureCache</a>, <a href="AbstractFSWAL.html#syncFutures">syncFutures</a>, <a href="AbstractFSWAL.html#totalLogSize">totalLogSize</a>, <a href="AbstractFSWAL.html#toWriteAppends">toWriteAppends</a>, <a href="AbstractFSWAL.html#unackedAppends">unackedAppends</a>, <a href="AbstractFSWAL.html#useHsync">useHsync</a>, <a href="AbstractFSWAL.html#WAL_AVOID_LOCAL_WRITES_DEFAULT">WAL_AVOID_LOCAL_WRITES_DEFAULT</a>, <a href="AbstractFSWAL.html#WAL_AVOID_LOCAL_WRITES_KEY">WAL_AVOID_LOCAL_WRITES_KEY</a>, <a href="AbstractFSWAL.html#WAL_ROLL_MULTIPLIER">WAL_ROLL_MULTIPLIER</a>, <a href="AbstractFSWAL.html#WAL_SHUTDOWN_WAIT_TIMEOUT_MS">WAL_SHUTDOWN_WAIT_TIMEOUT_MS</a>, <a href="AbstractFSWAL.html#WAL_SYNC_TIMEOUT_MS">WAL_SYNC_TIMEOUT_MS</a>, <a href="AbstractFSWAL.html#walArchiveDir">walArchiveDir</a>, <a href="AbstractFSWAL.html#walDir">walDir</a>, <a href="AbstractFSWAL.html#walFile2Props">walFile2Props</a>, <a href="AbstractFSWAL.html#walFilePrefix">walFilePrefix</a>, <a href="AbstractFSWAL.html#walFileSuffix">walFileSuffix</a>, <a href="AbstractFSWAL.html#walShutdownTimeout">walShutdownTimeout</a>, <a href="AbstractFSWAL.html#writer">writer</a></code></div> |
| </section> |
| </li> |
| <!-- ======== CONSTRUCTOR SUMMARY ======== --> |
| <li> |
| <section class="constructor-summary" id="constructor-summary"> |
| <h2>Constructor Summary</h2> |
| <div class="caption"><span>Constructors</span></div> |
| <div class="summary-table two-column-summary"> |
| <div class="table-header col-first">Constructor</div> |
| <div class="table-header col-last">Description</div> |
| <div class="col-constructor-name even-row-color"><code><a href="#%3Cinit%3E(org.apache.hadoop.fs.FileSystem,org.apache.hadoop.hbase.Abortable,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.fs.FileSystem,org.apache.hadoop.fs.Path,org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup,java.lang.Class,org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor)" class="member-name-link">AsyncFSWAL</a><wbr>(org.apache.hadoop.fs.FileSystem fs, |
| <a href="../../Abortable.html" title="interface in org.apache.hadoop.hbase">Abortable</a> abortable, |
| org.apache.hadoop.fs.Path rootDir, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a> logDir, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a> archiveDir, |
| org.apache.hadoop.conf.Configuration conf, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><<a href="WALActionsListener.html" title="interface in org.apache.hadoop.hbase.regionserver.wal">WALActionsListener</a>> listeners, |
| boolean failIfWALExists, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a> prefix, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a> suffix, |
| org.apache.hadoop.fs.FileSystem remoteFs, |
| org.apache.hadoop.fs.Path remoteWALDir, |
| org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Class.html" title="class or interface in java.lang" class="external-link">Class</a><? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass, |
| <a href="../../io/asyncfs/monitor/StreamSlowMonitor.html" title="class in org.apache.hadoop.hbase.io.asyncfs.monitor">StreamSlowMonitor</a> monitor)</code></div> |
| <div class="col-last even-row-color"> </div> |
| </div> |
| </section> |
| </li> |
| <!-- ========== METHOD SUMMARY =========== --> |
| <li> |
| <section class="method-summary" id="method-summary"> |
| <h2>Method Summary</h2> |
| <div id="method-summary-table"> |
| <div class="table-tabs" role="tablist" aria-orientation="horizontal"><button id="method-summary-table-tab0" role="tab" aria-selected="true" aria-controls="method-summary-table.tabpanel" tabindex="0" onkeydown="switchTab(event)" onclick="show('method-summary-table', 'method-summary-table', 3)" class="active-table-tab">All Methods</button><button id="method-summary-table-tab2" role="tab" aria-selected="false" aria-controls="method-summary-table.tabpanel" tabindex="-1" onkeydown="switchTab(event)" onclick="show('method-summary-table', 'method-summary-table-tab2', 3)" class="table-tab">Instance Methods</button><button id="method-summary-table-tab4" role="tab" aria-selected="false" aria-controls="method-summary-table.tabpanel" tabindex="-1" onkeydown="switchTab(event)" onclick="show('method-summary-table', 'method-summary-table-tab4', 3)" class="table-tab">Concrete Methods</button></div> |
| <div id="method-summary-table.tabpanel" role="tabpanel"> |
| <div class="summary-table three-column-summary" aria-labelledby="method-summary-table-tab0"> |
| <div class="table-header col-first">Modifier and Type</div> |
| <div class="table-header col-second">Method</div> |
| <div class="table-header col-last">Description</div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>protected final <a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a></code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#createAsyncWriter(org.apache.hadoop.fs.FileSystem,org.apache.hadoop.fs.Path)" class="member-name-link">createAsyncWriter</a><wbr>(org.apache.hadoop.fs.FileSystem fs, |
| org.apache.hadoop.fs.Path path)</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>protected <a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a></code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#createCombinedWriter(org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter,org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter)" class="member-name-link">createCombinedWriter</a><wbr>(<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> localWriter, |
| <a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> remoteWriter)</code></div> |
| <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>protected <a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a></code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#createWriterInstance(org.apache.hadoop.fs.FileSystem,org.apache.hadoop.fs.Path)" class="member-name-link">createWriterInstance</a><wbr>(org.apache.hadoop.fs.FileSystem fs, |
| org.apache.hadoop.fs.Path path)</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>protected void</code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#doAppend(org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter,org.apache.hadoop.hbase.regionserver.wal.FSWALEntry)" class="member-name-link">doAppend</a><wbr>(<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> writer, |
| <a href="FSWALEntry.html" title="class in org.apache.hadoop.hbase.regionserver.wal">FSWALEntry</a> entry)</code></div> |
| <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>protected boolean</code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#doCheckLogLowReplication()" class="member-name-link">doCheckLogLowReplication</a>()</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>protected <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/concurrent/CompletableFuture.html" title="class or interface in java.util.concurrent" class="external-link">CompletableFuture</a><<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Long.html" title="class or interface in java.lang" class="external-link">Long</a>></code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#doWriterSync(org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter,boolean,long)" class="member-name-link">doWriterSync</a><wbr>(<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> writer, |
| boolean shouldUseHsync, |
| long txidWhenSyn)</code></div> |
| <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>(package private) int</code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#getLogReplication()" class="member-name-link">getLogReplication</a>()</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> |
| <div class="block">This method gets the datanode replication count for the current WAL.</div> |
| </div> |
| <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>(package private) org.apache.hadoop.hdfs.protocol.DatanodeInfo[]</code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#getPipeline()" class="member-name-link">getPipeline</a>()</code></div> |
| <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> |
| <div class="block">This method gets the pipeline for the current WAL.</div> |
| </div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>protected void</code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#onWriterReplaced(org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter)" class="member-name-link">onWriterReplaced</a><wbr>(<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> nextWriter)</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> </div> |
| </div> |
| </div> |
| </div> |
| <div class="inherited-list"> |
| <h3 id="methods-inherited-from-class-org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL">Methods inherited from class org.apache.hadoop.hbase.regionserver.wal.<a href="AbstractFSWAL.html" title="class in org.apache.hadoop.hbase.regionserver.wal">AbstractFSWAL</a></h3> |
| <code><a href="AbstractFSWAL.html#abortCacheFlush(byte%5B%5D)">abortCacheFlush</a>, <a href="AbstractFSWAL.html#append(org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.wal.WALKeyImpl,org.apache.hadoop.hbase.wal.WALEdit,boolean)">append</a>, <a href="AbstractFSWAL.html#appendData(org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.wal.WALKeyImpl,org.apache.hadoop.hbase.wal.WALEdit)">appendData</a>, <a href="AbstractFSWAL.html#appendEntry(W,org.apache.hadoop.hbase.regionserver.wal.FSWALEntry)">appendEntry</a>, <a href="AbstractFSWAL.html#appendMarker(org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.wal.WALKeyImpl,org.apache.hadoop.hbase.wal.WALEdit)">appendMarker</a>, <a href="AbstractFSWAL.html#archive(org.apache.hadoop.hbase.util.Pair)">archive</a>, <a href="AbstractFSWAL.html#archiveLogFile(org.apache.hadoop.fs.Path)">archiveLogFile</a>, <a href="AbstractFSWAL.html#atHeadOfRingBufferEventHandlerAppend()">atHeadOfRingBufferEventHandlerAppend</a>, <a href="AbstractFSWAL.html#blockOnSync(org.apache.hadoop.hbase.regionserver.wal.SyncFuture)">blockOnSync</a>, <a href="AbstractFSWAL.html#checkLogLowReplication(long)">checkLogLowReplication</a>, <a href="AbstractFSWAL.html#checkSlowSyncCount()">checkSlowSyncCount</a>, <a href="AbstractFSWAL.html#close()">close</a>, <a href="AbstractFSWAL.html#closeWriter(W,org.apache.hadoop.fs.Path)">closeWriter</a>, <a href="AbstractFSWAL.html#completeCacheFlush(byte%5B%5D,long)">completeCacheFlush</a>, <a href="AbstractFSWAL.html#computeFilename(long)">computeFilename</a>, <a href="AbstractFSWAL.html#createSingleThreadPoolConsumeExecutor(java.lang.String,org.apache.hadoop.fs.Path,java.lang.String)">createSingleThreadPoolConsumeExecutor</a>, <a href="AbstractFSWAL.html#doCheckSlowSync()">doCheckSlowSync</a>, <a href="AbstractFSWAL.html#doCleanUpResources()">doCleanUpResources</a>, <a href="AbstractFSWAL.html#doReplaceWriter(org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path,W)">doReplaceWriter</a>, <a href="AbstractFSWAL.html#doShutdown()">doShutdown</a>, <a href="AbstractFSWAL.html#doSync(boolean)">doSync</a>, <a href="AbstractFSWAL.html#doSync(long,boolean)">doSync</a>, <a href="AbstractFSWAL.html#findRegionsToForceFlush()">findRegionsToForceFlush</a>, <a href="AbstractFSWAL.html#getCoprocessorHost()">getCoprocessorHost</a>, <a href="AbstractFSWAL.html#getCurrentFileName()">getCurrentFileName</a>, <a href="AbstractFSWAL.html#getEarliestMemStoreSeqNum(byte%5B%5D,byte%5B%5D)">getEarliestMemStoreSeqNum</a>, <a href="AbstractFSWAL.html#getFilenum()">getFilenum</a>, <a href="AbstractFSWAL.html#getFileNumFromFileName(org.apache.hadoop.fs.Path)">getFileNumFromFileName</a>, <a href="AbstractFSWAL.html#getFiles()">getFiles</a>, <a href="AbstractFSWAL.html#getInflightWALCloseCount()">getInflightWALCloseCount</a>, <a href="AbstractFSWAL.html#getLogFileSize()">getLogFileSize</a>, <a href="AbstractFSWAL.html#getLogFileSizeIfBeingWritten(org.apache.hadoop.fs.Path)">getLogFileSizeIfBeingWritten</a>, <a href="AbstractFSWAL.html#getNumLogFiles()">getNumLogFiles</a>, <a href="AbstractFSWAL.html#getNumRolledLogFiles()">getNumRolledLogFiles</a>, <a href="AbstractFSWAL.html#getOldPath()">getOldPath</a>, <a href="AbstractFSWAL.html#getPreallocatedEventCount()">getPreallocatedEventCount</a>, <a href="AbstractFSWAL.html#getSequenceIdAccounting()">getSequenceIdAccounting</a>, <a href="AbstractFSWAL.html#getSyncedTxid(long,long)">getSyncedTxid</a>, <a href="AbstractFSWAL.html#getSyncFuture(long,boolean)">getSyncFuture</a>, <a href="AbstractFSWAL.html#getUnflushedEntriesCount()">getUnflushedEntriesCount</a>, <a href="AbstractFSWAL.html#getWALArchivePath(org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path)">getWALArchivePath</a>, <a href="AbstractFSWAL.html#getWriter()">getWriter</a>, <a href="AbstractFSWAL.html#init()">init</a>, <a href="AbstractFSWAL.html#isLogRollRequested()">isLogRollRequested</a>, <a href="AbstractFSWAL.html#isUnflushedEntries()">isUnflushedEntries</a>, <a href="AbstractFSWAL.html#isWriterBroken()">isWriterBroken</a>, <a href="AbstractFSWAL.html#logRollAndSetupWalProps(org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path,long)">logRollAndSetupWalProps</a>, <a href="AbstractFSWAL.html#main(java.lang.String%5B%5D)">main</a>, <a href="AbstractFSWAL.html#markFutureDoneAndOffer(org.apache.hadoop.hbase.regionserver.wal.SyncFuture,long,java.lang.Throwable)">markFutureDoneAndOffer</a>, <a href="AbstractFSWAL.html#postSync(long,int)">postSync</a>, <a href="AbstractFSWAL.html#registerWALActionsListener(org.apache.hadoop.hbase.regionserver.wal.WALActionsListener)">registerWALActionsListener</a>, <a href="AbstractFSWAL.html#replaceWriter(org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path,W)">replaceWriter</a>, <a href="AbstractFSWAL.html#requestLogRoll()">requestLogRoll</a>, <a href="AbstractFSWAL.html#requestLogRoll(org.apache.hadoop.hbase.regionserver.wal.WALActionsListener.RollRequestReason)">requestLogRoll</a>, <a href="AbstractFSWAL.html#rollWriter()">rollWriter</a>, <a href="AbstractFSWAL.html#rollWriter(boolean)">rollWriter</a>, <a href="AbstractFSWAL.html#setWaitOnShutdownInSeconds(int,java.lang.String)">setWaitOnShutdownInSeconds</a>, <a href="AbstractFSWAL.html#shutdown()">shutdown</a>, <a href="AbstractFSWAL.html#skipRemoteWAL(boolean)">skipRemoteWAL</a>, <a href="AbstractFSWAL.html#stampSequenceIdAndPublishToRingBuffer(org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.wal.WALKeyImpl,org.apache.hadoop.hbase.wal.WALEdit,boolean,com.lmax.disruptor.RingBuffer)">stampSequenceIdAndPublishToRingBuffer</a>, <a href="AbstractFSWAL.html#startCacheFlush(byte%5B%5D,java.util.Map)">startCacheFlush</a>, <a href="AbstractFSWAL.html#startCacheFlush(byte%5B%5D,java.util.Set)">startCacheFlush</a>, <a href="AbstractFSWAL.html#sync()">sync</a>, <a href="AbstractFSWAL.html#sync(boolean)">sync</a>, <a href="AbstractFSWAL.html#sync(long)">sync</a>, <a href="AbstractFSWAL.html#sync(long,boolean)">sync</a>, <a href="AbstractFSWAL.html#toString()">toString</a>, <a href="AbstractFSWAL.html#unregisterWALActionsListener(org.apache.hadoop.hbase.regionserver.wal.WALActionsListener)">unregisterWALActionsListener</a>, <a href="AbstractFSWAL.html#updateStore(byte%5B%5D,byte%5B%5D,java.lang.Long,boolean)">updateStore</a>, <a href="AbstractFSWAL.html#waitForSafePoint()">waitForSafePoint</a></code></div> |
| <div class="inherited-list"> |
| <h3 id="methods-inherited-from-class-java.lang.Object">Methods inherited from class java.lang.<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html" title="class or interface in java.lang" class="external-link">Object</a></h3> |
| <code><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#clone()" title="class or interface in java.lang" class="external-link">clone</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#equals(java.lang.Object)" title="class or interface in java.lang" class="external-link">equals</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#finalize()" title="class or interface in java.lang" class="external-link">finalize</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#getClass()" title="class or interface in java.lang" class="external-link">getClass</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#hashCode()" title="class or interface in java.lang" class="external-link">hashCode</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#notify()" title="class or interface in java.lang" class="external-link">notify</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#notifyAll()" title="class or interface in java.lang" class="external-link">notifyAll</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#wait()" title="class or interface in java.lang" class="external-link">wait</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#wait(long)" title="class or interface in java.lang" class="external-link">wait</a>, <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Object.html#wait(long,int)" title="class or interface in java.lang" class="external-link">wait</a></code></div> |
| </section> |
| </li> |
| </ul> |
| </section> |
| <section class="details"> |
| <ul class="details-list"> |
| <!-- ============ FIELD DETAIL =========== --> |
| <li> |
| <section class="field-details" id="field-detail"> |
| <h2>Field Details</h2> |
| <ul class="member-list"> |
| <li> |
| <section class="detail" id="LOG"> |
| <h3>LOG</h3> |
| <div class="member-signature"><span class="modifiers">private static final</span> <span class="return-type">org.slf4j.Logger</span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-103">LOG</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="WAL_BATCH_SIZE"> |
| <h3>WAL_BATCH_SIZE</h3> |
| <div class="member-signature"><span class="modifiers">public static final</span> <span class="return-type"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a></span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-105">WAL_BATCH_SIZE</a></span></div> |
| <dl class="notes"> |
| <dt>See Also:</dt> |
| <dd> |
| <ul class="see-list"> |
| <li><a href="../../../../../../constant-values.html#org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL.WAL_BATCH_SIZE">Constant Field Values</a></li> |
| </ul> |
| </dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="DEFAULT_WAL_BATCH_SIZE"> |
| <h3>DEFAULT_WAL_BATCH_SIZE</h3> |
| <div class="member-signature"><span class="modifiers">public static final</span> <span class="return-type">long</span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-106">DEFAULT_WAL_BATCH_SIZE</a></span></div> |
| <dl class="notes"> |
| <dt>See Also:</dt> |
| <dd> |
| <ul class="see-list"> |
| <li><a href="../../../../../../constant-values.html#org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL.DEFAULT_WAL_BATCH_SIZE">Constant Field Values</a></li> |
| </ul> |
| </dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="ASYNC_WAL_USE_SHARED_EVENT_LOOP"> |
| <h3>ASYNC_WAL_USE_SHARED_EVENT_LOOP</h3> |
| <div class="member-signature"><span class="modifiers">public static final</span> <span class="return-type"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a></span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-108">ASYNC_WAL_USE_SHARED_EVENT_LOOP</a></span></div> |
| <dl class="notes"> |
| <dt>See Also:</dt> |
| <dd> |
| <ul class="see-list"> |
| <li><a href="../../../../../../constant-values.html#org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL.ASYNC_WAL_USE_SHARED_EVENT_LOOP">Constant Field Values</a></li> |
| </ul> |
| </dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="DEFAULT_ASYNC_WAL_USE_SHARED_EVENT_LOOP"> |
| <h3>DEFAULT_ASYNC_WAL_USE_SHARED_EVENT_LOOP</h3> |
| <div class="member-signature"><span class="modifiers">public static final</span> <span class="return-type">boolean</span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-110">DEFAULT_ASYNC_WAL_USE_SHARED_EVENT_LOOP</a></span></div> |
| <dl class="notes"> |
| <dt>See Also:</dt> |
| <dd> |
| <ul class="see-list"> |
| <li><a href="../../../../../../constant-values.html#org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL.DEFAULT_ASYNC_WAL_USE_SHARED_EVENT_LOOP">Constant Field Values</a></li> |
| </ul> |
| </dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="ASYNC_WAL_WAIT_ON_SHUTDOWN_IN_SECONDS"> |
| <h3>ASYNC_WAL_WAIT_ON_SHUTDOWN_IN_SECONDS</h3> |
| <div class="member-signature"><span class="modifiers">public static final</span> <span class="return-type"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a></span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-112">ASYNC_WAL_WAIT_ON_SHUTDOWN_IN_SECONDS</a></span></div> |
| <dl class="notes"> |
| <dt>See Also:</dt> |
| <dd> |
| <ul class="see-list"> |
| <li><a href="../../../../../../constant-values.html#org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL.ASYNC_WAL_WAIT_ON_SHUTDOWN_IN_SECONDS">Constant Field Values</a></li> |
| </ul> |
| </dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="DEFAULT_ASYNC_WAL_WAIT_ON_SHUTDOWN_IN_SECONDS"> |
| <h3>DEFAULT_ASYNC_WAL_WAIT_ON_SHUTDOWN_IN_SECONDS</h3> |
| <div class="member-signature"><span class="modifiers">public static final</span> <span class="return-type">int</span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-114">DEFAULT_ASYNC_WAL_WAIT_ON_SHUTDOWN_IN_SECONDS</a></span></div> |
| <dl class="notes"> |
| <dt>See Also:</dt> |
| <dd> |
| <ul class="see-list"> |
| <li><a href="../../../../../../constant-values.html#org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL.DEFAULT_ASYNC_WAL_WAIT_ON_SHUTDOWN_IN_SECONDS">Constant Field Values</a></li> |
| </ul> |
| </dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="eventLoopGroup"> |
| <h3>eventLoopGroup</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type">org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup</span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-116">eventLoopGroup</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="channelClass"> |
| <h3>channelClass</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Class.html" title="class or interface in java.lang" class="external-link">Class</a><? extends org.apache.hbase.thirdparty.io.netty.channel.Channel></span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-118">channelClass</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="fsOut"> |
| <h3>fsOut</h3> |
| <div class="member-signature"><span class="modifiers">private volatile</span> <span class="return-type"><a href="../../io/asyncfs/AsyncFSOutput.html" title="interface in org.apache.hadoop.hbase.io.asyncfs">AsyncFSOutput</a></span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-120">fsOut</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="streamSlowMonitor"> |
| <h3>streamSlowMonitor</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type"><a href="../../io/asyncfs/monitor/StreamSlowMonitor.html" title="class in org.apache.hadoop.hbase.io.asyncfs.monitor">StreamSlowMonitor</a></span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-122">streamSlowMonitor</a></span></div> |
| </section> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <!-- ========= CONSTRUCTOR DETAIL ======== --> |
| <li> |
| <section class="constructor-details" id="constructor-detail"> |
| <h2>Constructor Details</h2> |
| <ul class="member-list"> |
| <li> |
| <section class="detail" id="<init>(org.apache.hadoop.fs.FileSystem,org.apache.hadoop.hbase.Abortable,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.fs.FileSystem,org.apache.hadoop.fs.Path,org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup,java.lang.Class,org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor)"> |
| <h3>AsyncFSWAL</h3> |
| <div class="member-signature"><span class="modifiers">public</span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-124">AsyncFSWAL</a></span><wbr><span class="parameters">(org.apache.hadoop.fs.FileSystem fs, |
| <a href="../../Abortable.html" title="interface in org.apache.hadoop.hbase">Abortable</a> abortable, |
| org.apache.hadoop.fs.Path rootDir, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a> logDir, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a> archiveDir, |
| org.apache.hadoop.conf.Configuration conf, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/List.html" title="class or interface in java.util" class="external-link">List</a><<a href="WALActionsListener.html" title="interface in org.apache.hadoop.hbase.regionserver.wal">WALActionsListener</a>> listeners, |
| boolean failIfWALExists, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a> prefix, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/String.html" title="class or interface in java.lang" class="external-link">String</a> suffix, |
| org.apache.hadoop.fs.FileSystem remoteFs, |
| org.apache.hadoop.fs.Path remoteWALDir, |
| org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Class.html" title="class or interface in java.lang" class="external-link">Class</a><? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass, |
| <a href="../../io/asyncfs/monitor/StreamSlowMonitor.html" title="class in org.apache.hadoop.hbase.io.asyncfs.monitor">StreamSlowMonitor</a> monitor)</span> |
| throws <span class="exceptions"><a href="FailedLogCloseException.html" title="class in org.apache.hadoop.hbase.regionserver.wal">FailedLogCloseException</a>, |
| <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/io/IOException.html" title="class or interface in java.io" class="external-link">IOException</a></span></div> |
| <dl class="notes"> |
| <dt>Throws:</dt> |
| <dd><code><a href="FailedLogCloseException.html" title="class in org.apache.hadoop.hbase.regionserver.wal">FailedLogCloseException</a></code></dd> |
| <dd><code><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/io/IOException.html" title="class or interface in java.io" class="external-link">IOException</a></code></dd> |
| </dl> |
| </section> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <!-- ============ METHOD DETAIL ========== --> |
| <li> |
| <section class="method-details" id="method-detail"> |
| <h2>Method Details</h2> |
| <ul class="member-list"> |
| <li> |
| <section class="detail" id="doWriterSync(org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter,boolean,long)"> |
| <h3>doWriterSync</h3> |
| <div class="member-signature"><span class="modifiers">protected</span> <span class="return-type"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/concurrent/CompletableFuture.html" title="class or interface in java.util.concurrent" class="external-link">CompletableFuture</a><<a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/lang/Long.html" title="class or interface in java.lang" class="external-link">Long</a>></span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-159">doWriterSync</a></span><wbr><span class="parameters">(<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> writer, |
| boolean shouldUseHsync, |
| long txidWhenSyn)</span></div> |
| <dl class="notes"> |
| <dt>Specified by:</dt> |
| <dd><code><a href="AbstractFSWAL.html#doWriterSync(W,boolean,long)">doWriterSync</a></code> in class <code><a href="AbstractFSWAL.html" title="class in org.apache.hadoop.hbase.regionserver.wal">AbstractFSWAL</a><<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a>></code></dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="createAsyncWriter(org.apache.hadoop.fs.FileSystem,org.apache.hadoop.fs.Path)"> |
| <h3>createAsyncWriter</h3> |
| <div class="member-signature"><span class="modifiers">protected final</span> <span class="return-type"><a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a></span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-165">createAsyncWriter</a></span><wbr><span class="parameters">(org.apache.hadoop.fs.FileSystem fs, |
| org.apache.hadoop.fs.Path path)</span> |
| throws <span class="exceptions"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/io/IOException.html" title="class or interface in java.io" class="external-link">IOException</a></span></div> |
| <dl class="notes"> |
| <dt>Throws:</dt> |
| <dd><code><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/io/IOException.html" title="class or interface in java.io" class="external-link">IOException</a></code></dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="createWriterInstance(org.apache.hadoop.fs.FileSystem,org.apache.hadoop.fs.Path)"> |
| <h3>createWriterInstance</h3> |
| <div class="member-signature"><span class="modifiers">protected</span> <span class="return-type"><a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a></span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-170">createWriterInstance</a></span><wbr><span class="parameters">(org.apache.hadoop.fs.FileSystem fs, |
| org.apache.hadoop.fs.Path path)</span> |
| throws <span class="exceptions"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/io/IOException.html" title="class or interface in java.io" class="external-link">IOException</a></span></div> |
| <dl class="notes"> |
| <dt>Specified by:</dt> |
| <dd><code><a href="AbstractFSWAL.html#createWriterInstance(org.apache.hadoop.fs.FileSystem,org.apache.hadoop.fs.Path)">createWriterInstance</a></code> in class <code><a href="AbstractFSWAL.html" title="class in org.apache.hadoop.hbase.regionserver.wal">AbstractFSWAL</a><<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a>></code></dd> |
| <dt>Throws:</dt> |
| <dd><code><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/io/IOException.html" title="class or interface in java.io" class="external-link">IOException</a></code></dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="onWriterReplaced(org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter)"> |
| <h3>onWriterReplaced</h3> |
| <div class="member-signature"><span class="modifiers">protected</span> <span class="return-type">void</span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-175">onWriterReplaced</a></span><wbr><span class="parameters">(<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> nextWriter)</span></div> |
| <dl class="notes"> |
| <dt>Specified by:</dt> |
| <dd><code><a href="AbstractFSWAL.html#onWriterReplaced(W)">onWriterReplaced</a></code> in class <code><a href="AbstractFSWAL.html" title="class in org.apache.hadoop.hbase.regionserver.wal">AbstractFSWAL</a><<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a>></code></dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="doAppend(org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter,org.apache.hadoop.hbase.regionserver.wal.FSWALEntry)"> |
| <h3>doAppend</h3> |
| <div class="member-signature"><span class="modifiers">protected</span> <span class="return-type">void</span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-182">doAppend</a></span><wbr><span class="parameters">(<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> writer, |
| <a href="FSWALEntry.html" title="class in org.apache.hadoop.hbase.regionserver.wal">FSWALEntry</a> entry)</span></div> |
| <dl class="notes"> |
| <dt>Specified by:</dt> |
| <dd><code><a href="AbstractFSWAL.html#doAppend(W,org.apache.hadoop.hbase.regionserver.wal.FSWALEntry)">doAppend</a></code> in class <code><a href="AbstractFSWAL.html" title="class in org.apache.hadoop.hbase.regionserver.wal">AbstractFSWAL</a><<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a>></code></dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="getPipeline()"> |
| <h3>getPipeline</h3> |
| <div class="member-signature"><span class="return-type">org.apache.hadoop.hdfs.protocol.DatanodeInfo[]</span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-187">getPipeline</a></span>()</div> |
| <div class="block"><span class="descfrm-type-label">Description copied from class: <code><a href="AbstractFSWAL.html#getPipeline()">AbstractFSWAL</a></code></span></div> |
| <div class="block">This method gets the pipeline for the current WAL.</div> |
| <dl class="notes"> |
| <dt>Specified by:</dt> |
| <dd><code><a href="AbstractFSWAL.html#getPipeline()">getPipeline</a></code> in class <code><a href="AbstractFSWAL.html" title="class in org.apache.hadoop.hbase.regionserver.wal">AbstractFSWAL</a><<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a>></code></dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="getLogReplication()"> |
| <h3>getLogReplication</h3> |
| <div class="member-signature"><span class="return-type">int</span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-193">getLogReplication</a></span>()</div> |
| <div class="block"><span class="descfrm-type-label">Description copied from class: <code><a href="AbstractFSWAL.html#getLogReplication()">AbstractFSWAL</a></code></span></div> |
| <div class="block">This method gets the datanode replication count for the current WAL.</div> |
| <dl class="notes"> |
| <dt>Specified by:</dt> |
| <dd><code><a href="AbstractFSWAL.html#getLogReplication()">getLogReplication</a></code> in class <code><a href="AbstractFSWAL.html" title="class in org.apache.hadoop.hbase.regionserver.wal">AbstractFSWAL</a><<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a>></code></dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="doCheckLogLowReplication()"> |
| <h3>doCheckLogLowReplication</h3> |
| <div class="member-signature"><span class="modifiers">protected</span> <span class="return-type">boolean</span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-198">doCheckLogLowReplication</a></span>()</div> |
| <dl class="notes"> |
| <dt>Specified by:</dt> |
| <dd><code><a href="AbstractFSWAL.html#doCheckLogLowReplication()">doCheckLogLowReplication</a></code> in class <code><a href="AbstractFSWAL.html" title="class in org.apache.hadoop.hbase.regionserver.wal">AbstractFSWAL</a><<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a>></code></dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="createCombinedWriter(org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter,org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter)"> |
| <h3>createCombinedWriter</h3> |
| <div class="member-signature"><span class="modifiers">protected</span> <span class="return-type"><a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a></span> <span class="element-name"><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.html#line-206">createCombinedWriter</a></span><wbr><span class="parameters">(<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> localWriter, |
| <a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a> remoteWriter)</span></div> |
| <dl class="notes"> |
| <dt>Specified by:</dt> |
| <dd><code><a href="AbstractFSWAL.html#createCombinedWriter(W,W)">createCombinedWriter</a></code> in class <code><a href="AbstractFSWAL.html" title="class in org.apache.hadoop.hbase.regionserver.wal">AbstractFSWAL</a><<a href="../../wal/WALProvider.AsyncWriter.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.AsyncWriter</a>></code></dd> |
| </dl> |
| </section> |
| </li> |
| </ul> |
| </section> |
| </li> |
| </ul> |
| </section> |
| <!-- ========= END OF CLASS DATA ========= --> |
| </main> |
| <footer role="contentinfo"> |
| <hr> |
| <p class="legal-copy"><small>Copyright © 2007–2020 <a href="https://www.apache.org/">The Apache Software Foundation</a>. All rights reserved.</small></p> |
| </footer> |
| </div> |
| </div> |
| </body> |
| </html> |
