| <!DOCTYPE HTML> |
| <html lang="en"> |
| <head> |
| <!-- Generated by javadoc (17) --> |
| <title>WALSplitter (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.wal, class: WALSplitter"> |
| <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/WALSplitter.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.wal</a></div> |
| <h1 title="Class WALSplitter" class="title">Class WALSplitter</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">org.apache.hadoop.hbase.wal.WALSplitter</div> |
| </div> |
| <section class="class-description" id="class-description"> |
| <hr> |
| <div class="type-signature"><span class="annotations">@Private |
| </span><span class="modifiers">public class </span><span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-69">WALSplitter</a></span> |
| <span class="extends-implements">extends <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></span></div> |
| <div class="block">Split RegionServer WAL files. Splits the WAL into new files, one per region, to be picked up on |
| Region reopen. Deletes the split WAL when finished. Create an instance and call |
| <a href="#splitWAL(org.apache.hadoop.fs.FileStatus,org.apache.hadoop.hbase.util.CancelableProgressable)"><code>splitWAL(FileStatus, CancelableProgressable)</code></a> per file or use static helper methods.</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="caption"><span>Nested Classes</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">Class</div> |
| <div class="table-header col-last">Description</div> |
| <div class="col-first even-row-color"><code>(package private) static class </code></div> |
| <div class="col-second even-row-color"><code><a href="WALSplitter.CorruptedLogFileException.html" class="type-name-link" title="class in org.apache.hadoop.hbase.wal">WALSplitter.CorruptedLogFileException</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>static class </code></div> |
| <div class="col-second odd-row-color"><code><a href="WALSplitter.PipelineController.html" class="type-name-link" title="class in org.apache.hadoop.hbase.wal">WALSplitter.PipelineController</a></code></div> |
| <div class="col-last odd-row-color"> |
| <div class="block">Contains some methods to control WAL-entries producer / consumer interactions</div> |
| </div> |
| <div class="col-first even-row-color"><code>(package private) static final class </code></div> |
| <div class="col-second even-row-color"><code><a href="WALSplitter.SplitWALResult.html" class="type-name-link" title="class in org.apache.hadoop.hbase.wal">WALSplitter.SplitWALResult</a></code></div> |
| <div class="col-last even-row-color"> |
| <div class="block">Data structure returned as result by #splitWAL(FileStatus, CancelableProgressable).</div> |
| </div> |
| </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>private final long</code></div> |
| <div class="col-second even-row-color"><code><a href="#bufferSize" class="member-name-link">bufferSize</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>protected final org.apache.hadoop.conf.Configuration</code></div> |
| <div class="col-second odd-row-color"><code><a href="#conf" class="member-name-link">conf</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>static final boolean</code></div> |
| <div class="col-second even-row-color"><code><a href="#DEFAULT_WAL_SPLIT_TO_HFILE" class="member-name-link">DEFAULT_WAL_SPLIT_TO_HFILE</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>private <a href="EntryBuffers.html" title="class in org.apache.hadoop.hbase.wal">EntryBuffers</a></code></div> |
| <div class="col-second odd-row-color"><code><a href="#entryBuffers" class="member-name-link">entryBuffers</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>private org.apache.hadoop.fs.FileStatus</code></div> |
| <div class="col-second even-row-color"><code><a href="#fileBeingSplit" class="member-name-link">fileBeingSplit</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>private final boolean</code></div> |
| <div class="col-second odd-row-color"><code><a href="#hfile" class="member-name-link">hfile</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>protected <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><<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>,<wbr><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 even-row-color"><code><a href="#lastFlushedSequenceIds" class="member-name-link">lastFlushedSequenceIds</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>private static final org.slf4j.Logger</code></div> |
| <div class="col-second odd-row-color"><code><a href="#LOG" class="member-name-link">LOG</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>private final int</code></div> |
| <div class="col-second even-row-color"><code><a href="#numWriterThreads" class="member-name-link">numWriterThreads</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>(package private) <a href="OutputSink.html" title="class in org.apache.hadoop.hbase.wal">OutputSink</a></code></div> |
| <div class="col-second odd-row-color"><code><a href="#outputSink" class="member-name-link">outputSink</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>protected <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><<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>,<wbr><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><byte[],<wbr><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 even-row-color"><code><a href="#regionMaxSeqIdInStores" class="member-name-link">regionMaxSeqIdInStores</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>(package private) final org.apache.hadoop.fs.Path</code></div> |
| <div class="col-second odd-row-color"><code><a href="#rootDir" class="member-name-link">rootDir</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>(package private) final org.apache.hadoop.fs.FileSystem</code></div> |
| <div class="col-second even-row-color"><code><a href="#rootFS" class="member-name-link">rootFS</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>(package private) final <a href="../regionserver/RegionServerServices.html" title="interface in org.apache.hadoop.hbase.regionserver">RegionServerServices</a></code></div> |
| <div class="col-second odd-row-color"><code><a href="#rsServices" class="member-name-link">rsServices</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>protected final <a href="../regionserver/LastSequenceId.html" title="interface in org.apache.hadoop.hbase.regionserver">LastSequenceId</a></code></div> |
| <div class="col-second even-row-color"><code><a href="#sequenceIdChecker" class="member-name-link">sequenceIdChecker</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>private final boolean</code></div> |
| <div class="col-second odd-row-color"><code><a href="#skipErrors" class="member-name-link">skipErrors</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>static final boolean</code></div> |
| <div class="col-second even-row-color"><code><a href="#SPLIT_SKIP_ERRORS_DEFAULT" class="member-name-link">SPLIT_SKIP_ERRORS_DEFAULT</a></code></div> |
| <div class="col-last even-row-color"> |
| <div class="block">By default we retry errors in splitting, rather than skipping.</div> |
| </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="#SPLIT_SKIP_ERRORS_KEY" class="member-name-link">SPLIT_SKIP_ERRORS_KEY</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="#SPLIT_WAL_BUFFER_SIZE" class="member-name-link">SPLIT_WAL_BUFFER_SIZE</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="#SPLIT_WAL_WRITER_THREADS" class="member-name-link">SPLIT_WAL_WRITER_THREADS</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="#SPLIT_WRITER_CREATION_BOUNDED" class="member-name-link">SPLIT_WRITER_CREATION_BOUNDED</a></code></div> |
| <div class="col-last even-row-color"> |
| <div class="block">True if we are to run with bounded amount of writers rather than let the count blossom.</div> |
| </div> |
| <div class="col-first odd-row-color"><code>private <a href="../coordination/SplitLogWorkerCoordination.html" title="interface in org.apache.hadoop.hbase.coordination">SplitLogWorkerCoordination</a></code></div> |
| <div class="col-second odd-row-color"><code><a href="#splitLogWorkerCoordination" class="member-name-link">splitLogWorkerCoordination</a></code></div> |
| <div class="col-last odd-row-color"> |
| <div class="block">Coordinator for split log.</div> |
| </div> |
| <div class="col-first even-row-color"><code>private final boolean</code></div> |
| <div class="col-second even-row-color"><code><a href="#splitWriterCreationBounded" class="member-name-link">splitWriterCreationBounded</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>private 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="#tmpDirName" class="member-name-link">tmpDirName</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_SPLIT_TO_HFILE" class="member-name-link">WAL_SPLIT_TO_HFILE</a></code></div> |
| <div class="col-last even-row-color"> |
| <div class="block">Split WAL directly to hfiles instead of into intermediary 'recovered.edits' files.</div> |
| </div> |
| <div class="col-first odd-row-color"><code>private final <a href="WALFactory.html" title="class in org.apache.hadoop.hbase.wal">WALFactory</a></code></div> |
| <div class="col-second odd-row-color"><code><a href="#walFactory" class="member-name-link">walFactory</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| <div class="col-first even-row-color"><code>protected final org.apache.hadoop.fs.FileSystem</code></div> |
| <div class="col-second even-row-color"><code><a href="#walFS" class="member-name-link">walFS</a></code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-first odd-row-color"><code>protected final org.apache.hadoop.fs.Path</code></div> |
| <div class="col-second odd-row-color"><code><a href="#walRootDir" class="member-name-link">walRootDir</a></code></div> |
| <div class="col-last odd-row-color"> </div> |
| </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.hbase.wal.WALFactory,org.apache.hadoop.conf.Configuration,org.apache.hadoop.fs.Path,org.apache.hadoop.fs.FileSystem,org.apache.hadoop.fs.Path,org.apache.hadoop.fs.FileSystem)" class="member-name-link">WALSplitter</a><wbr>(<a href="WALFactory.html" title="class in org.apache.hadoop.hbase.wal">WALFactory</a> factory, |
| org.apache.hadoop.conf.Configuration conf, |
| org.apache.hadoop.fs.Path walRootDir, |
| org.apache.hadoop.fs.FileSystem walFS, |
| org.apache.hadoop.fs.Path rootDir, |
| org.apache.hadoop.fs.FileSystem rootFS)</code></div> |
| <div class="col-last even-row-color"> </div> |
| <div class="col-constructor-name odd-row-color"><code><a href="#%3Cinit%3E(org.apache.hadoop.hbase.wal.WALFactory,org.apache.hadoop.conf.Configuration,org.apache.hadoop.fs.Path,org.apache.hadoop.fs.FileSystem,org.apache.hadoop.fs.Path,org.apache.hadoop.fs.FileSystem,org.apache.hadoop.hbase.regionserver.LastSequenceId,org.apache.hadoop.hbase.coordination.SplitLogWorkerCoordination,org.apache.hadoop.hbase.regionserver.RegionServerServices)" class="member-name-link">WALSplitter</a><wbr>(<a href="WALFactory.html" title="class in org.apache.hadoop.hbase.wal">WALFactory</a> factory, |
| org.apache.hadoop.conf.Configuration conf, |
| org.apache.hadoop.fs.Path walRootDir, |
| org.apache.hadoop.fs.FileSystem walFS, |
| org.apache.hadoop.fs.Path rootDir, |
| org.apache.hadoop.fs.FileSystem rootFS, |
| <a href="../regionserver/LastSequenceId.html" title="interface in org.apache.hadoop.hbase.regionserver">LastSequenceId</a> idChecker, |
| <a href="../coordination/SplitLogWorkerCoordination.html" title="interface in org.apache.hadoop.hbase.coordination">SplitLogWorkerCoordination</a> splitLogWorkerCoordination, |
| <a href="../regionserver/RegionServerServices.html" title="interface in org.apache.hadoop.hbase.regionserver">RegionServerServices</a> rsServices)</code></div> |
| <div class="col-last odd-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-tab1" role="tab" aria-selected="false" aria-controls="method-summary-table.tabpanel" tabindex="-1" onkeydown="switchTab(event)" onclick="show('method-summary-table', 'method-summary-table-tab1', 3)" class="table-tab">Static 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>private void</code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#createOutputSinkAndEntryBuffers()" class="member-name-link">createOutputSinkAndEntryBuffers</a>()</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> |
| <div class="block">Setup the output sinks and entry buffers ahead of splitting WAL.</div> |
| </div> |
| <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>protected <a href="WALProvider.Writer.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.Writer</a></code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#createWriter(org.apache.hadoop.fs.Path)" class="member-name-link">createWriter</a><wbr>(org.apache.hadoop.fs.Path logfile)</code></div> |
| <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> |
| <div class="block">Create a new <a href="WALProvider.Writer.html" title="interface in org.apache.hadoop.hbase.wal"><code>WALProvider.Writer</code></a> for writing log splits.</div> |
| </div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>(package private) org.apache.hadoop.fs.FileStatus</code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#getFileBeingSplit()" class="member-name-link">getFileBeingSplit</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>private <a href="WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a></code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#getNextLogLine(org.apache.hadoop.hbase.wal.WALStreamReader,org.apache.hadoop.fs.Path,boolean)" class="member-name-link">getNextLogLine</a><wbr>(<a href="WALStreamReader.html" title="interface in org.apache.hadoop.hbase.wal">WALStreamReader</a> in, |
| org.apache.hadoop.fs.Path path, |
| boolean skipErrors)</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>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="#getNumOpenWriters()" class="member-name-link">getNumOpenWriters</a>()</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> |
| <div class="block">Get current open writers</div> |
| </div> |
| <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>protected <a href="WALStreamReader.html" title="interface in org.apache.hadoop.hbase.wal">WALStreamReader</a></code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#getReader(org.apache.hadoop.fs.FileStatus,boolean,org.apache.hadoop.hbase.util.CancelableProgressable)" class="member-name-link">getReader</a><wbr>(org.apache.hadoop.fs.FileStatus walStatus, |
| boolean skipErrors, |
| <a href="../util/CancelableProgressable.html" title="interface in org.apache.hadoop.hbase.util">CancelableProgressable</a> cancel)</code></div> |
| <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> |
| <div class="block">Create a new <a href="WALStreamReader.html" title="interface in org.apache.hadoop.hbase.wal"><code>WALStreamReader</code></a> for reading logs to split.</div> |
| </div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>private <a href="WALStreamReader.html" title="interface in org.apache.hadoop.hbase.wal">WALStreamReader</a></code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#getReader(org.apache.hadoop.fs.Path,org.apache.hadoop.hbase.util.CancelableProgressable)" class="member-name-link">getReader</a><wbr>(org.apache.hadoop.fs.Path curLogFile, |
| <a href="../util/CancelableProgressable.html" title="interface in org.apache.hadoop.hbase.util">CancelableProgressable</a> reporter)</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> |
| <div class="block">Create a new <a href="WALStreamReader.html" title="interface in org.apache.hadoop.hbase.wal"><code>WALStreamReader</code></a> for reading logs to split.</div> |
| </div> |
| <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>(package private) <a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><<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>,<wbr><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><byte[],<wbr><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="#getRegionMaxSeqIdInStores()" class="member-name-link">getRegionMaxSeqIdInStores</a>()</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) <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 method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#getTmpDirName()" class="member-name-link">getTmpDirName</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>(package private) <a href="WALFactory.html" title="class in org.apache.hadoop.hbase.wal">WALFactory</a></code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#getWalFactory()" class="member-name-link">getWalFactory</a>()</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>private boolean</code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#isRegionDirPresentUnderRoot(org.apache.hadoop.hbase.TableName,java.lang.String)" class="member-name-link">isRegionDirPresentUnderRoot</a><wbr>(<a href="../TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tn, |
| <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> region)</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-tab1 method-summary-table-tab4"><code>static <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><org.apache.hadoop.fs.Path></code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab1 method-summary-table-tab4"><code><a href="#split(org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path,org.apache.hadoop.fs.FileSystem,org.apache.hadoop.conf.Configuration,org.apache.hadoop.hbase.wal.WALFactory)" class="member-name-link">split</a><wbr>(org.apache.hadoop.fs.Path walRootDir, |
| org.apache.hadoop.fs.Path walsDir, |
| org.apache.hadoop.fs.Path archiveDir, |
| org.apache.hadoop.fs.FileSystem walFS, |
| org.apache.hadoop.conf.Configuration conf, |
| <a href="WALFactory.html" title="class in org.apache.hadoop.hbase.wal">WALFactory</a> factory)</code></div> |
| <div class="col-last odd-row-color method-summary-table method-summary-table-tab1 method-summary-table-tab4"> |
| <div class="block">Split a folder of WAL files.</div> |
| </div> |
| <div class="col-first even-row-color method-summary-table method-summary-table-tab1 method-summary-table-tab4"><code>static boolean</code></div> |
| <div class="col-second even-row-color method-summary-table method-summary-table-tab1 method-summary-table-tab4"><code><a href="#splitLogFile(org.apache.hadoop.fs.Path,org.apache.hadoop.fs.FileStatus,org.apache.hadoop.fs.FileSystem,org.apache.hadoop.conf.Configuration,org.apache.hadoop.hbase.util.CancelableProgressable,org.apache.hadoop.hbase.regionserver.LastSequenceId,org.apache.hadoop.hbase.coordination.SplitLogWorkerCoordination,org.apache.hadoop.hbase.wal.WALFactory,org.apache.hadoop.hbase.regionserver.RegionServerServices)" class="member-name-link">splitLogFile</a><wbr>(org.apache.hadoop.fs.Path walDir, |
| org.apache.hadoop.fs.FileStatus logfile, |
| org.apache.hadoop.fs.FileSystem walFS, |
| org.apache.hadoop.conf.Configuration conf, |
| <a href="../util/CancelableProgressable.html" title="interface in org.apache.hadoop.hbase.util">CancelableProgressable</a> reporter, |
| <a href="../regionserver/LastSequenceId.html" title="interface in org.apache.hadoop.hbase.regionserver">LastSequenceId</a> idChecker, |
| <a href="../coordination/SplitLogWorkerCoordination.html" title="interface in org.apache.hadoop.hbase.coordination">SplitLogWorkerCoordination</a> splitLogWorkerCoordination, |
| <a href="WALFactory.html" title="class in org.apache.hadoop.hbase.wal">WALFactory</a> factory, |
| <a href="../regionserver/RegionServerServices.html" title="interface in org.apache.hadoop.hbase.regionserver">RegionServerServices</a> rsServices)</code></div> |
| <div class="col-last even-row-color method-summary-table method-summary-table-tab1 method-summary-table-tab4"> |
| <div class="block">Splits a WAL file.</div> |
| </div> |
| <div class="col-first odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code>(package private) <a href="WALSplitter.SplitWALResult.html" title="class in org.apache.hadoop.hbase.wal">WALSplitter.SplitWALResult</a></code></div> |
| <div class="col-second odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"><code><a href="#splitWAL(org.apache.hadoop.fs.FileStatus,org.apache.hadoop.hbase.util.CancelableProgressable)" class="member-name-link">splitWAL</a><wbr>(org.apache.hadoop.fs.FileStatus walStatus, |
| <a href="../util/CancelableProgressable.html" title="interface in org.apache.hadoop.hbase.util">CancelableProgressable</a> cancel)</code></div> |
| <div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab4"> |
| <div class="block">WAL splitting implementation, splits one WAL file.</div> |
| </div> |
| </div> |
| </div> |
| </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#toString()" title="class or interface in java.lang" class="external-link">toString</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/wal/WALSplitter.html#line-71">LOG</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="SPLIT_SKIP_ERRORS_KEY"> |
| <h3>SPLIT_SKIP_ERRORS_KEY</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/wal/WALSplitter.html#line-72">SPLIT_SKIP_ERRORS_KEY</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.wal.WALSplitter.SPLIT_SKIP_ERRORS_KEY">Constant Field Values</a></li> |
| </ul> |
| </dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="SPLIT_SKIP_ERRORS_DEFAULT"> |
| <h3>SPLIT_SKIP_ERRORS_DEFAULT</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/wal/WALSplitter.html#line-77">SPLIT_SKIP_ERRORS_DEFAULT</a></span></div> |
| <div class="block">By default we retry errors in splitting, rather than skipping.</div> |
| <dl class="notes"> |
| <dt>See Also:</dt> |
| <dd> |
| <ul class="see-list"> |
| <li><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.wal.WALSplitter.SPLIT_SKIP_ERRORS_DEFAULT">Constant Field Values</a></li> |
| </ul> |
| </dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="walRootDir"> |
| <h3>walRootDir</h3> |
| <div class="member-signature"><span class="modifiers">protected final</span> <span class="return-type">org.apache.hadoop.fs.Path</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-80">walRootDir</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="walFS"> |
| <h3>walFS</h3> |
| <div class="member-signature"><span class="modifiers">protected final</span> <span class="return-type">org.apache.hadoop.fs.FileSystem</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-81">walFS</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="conf"> |
| <h3>conf</h3> |
| <div class="member-signature"><span class="modifiers">protected final</span> <span class="return-type">org.apache.hadoop.conf.Configuration</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-82">conf</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="rootDir"> |
| <h3>rootDir</h3> |
| <div class="member-signature"><span class="modifiers">final</span> <span class="return-type">org.apache.hadoop.fs.Path</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-83">rootDir</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="rootFS"> |
| <h3>rootFS</h3> |
| <div class="member-signature"><span class="modifiers">final</span> <span class="return-type">org.apache.hadoop.fs.FileSystem</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-84">rootFS</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="rsServices"> |
| <h3>rsServices</h3> |
| <div class="member-signature"><span class="modifiers">final</span> <span class="return-type"><a href="../regionserver/RegionServerServices.html" title="interface in org.apache.hadoop.hbase.regionserver">RegionServerServices</a></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-85">rsServices</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="outputSink"> |
| <h3>outputSink</h3> |
| <div class="member-signature"><span class="return-type"><a href="OutputSink.html" title="class in org.apache.hadoop.hbase.wal">OutputSink</a></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-89">outputSink</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="entryBuffers"> |
| <h3>entryBuffers</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type"><a href="EntryBuffers.html" title="class in org.apache.hadoop.hbase.wal">EntryBuffers</a></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-90">entryBuffers</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="splitLogWorkerCoordination"> |
| <h3>splitLogWorkerCoordination</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type"><a href="../coordination/SplitLogWorkerCoordination.html" title="interface in org.apache.hadoop.hbase.coordination">SplitLogWorkerCoordination</a></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-96">splitLogWorkerCoordination</a></span></div> |
| <div class="block">Coordinator for split log. Used by the zk-based log splitter. Not used by the procedure |
| v2-based log splitter.</div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="walFactory"> |
| <h3>walFactory</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type"><a href="WALFactory.html" title="class in org.apache.hadoop.hbase.wal">WALFactory</a></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-98">walFactory</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="sequenceIdChecker"> |
| <h3>sequenceIdChecker</h3> |
| <div class="member-signature"><span class="modifiers">protected final</span> <span class="return-type"><a href="../regionserver/LastSequenceId.html" title="interface in org.apache.hadoop.hbase.regionserver">LastSequenceId</a></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-101">sequenceIdChecker</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="lastFlushedSequenceIds"> |
| <h3>lastFlushedSequenceIds</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/Map.html" title="class or interface in java.util" class="external-link">Map</a><<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>,<wbr><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/wal/WALSplitter.html#line-104">lastFlushedSequenceIds</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="regionMaxSeqIdInStores"> |
| <h3>regionMaxSeqIdInStores</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/Map.html" title="class or interface in java.util" class="external-link">Map</a><<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>,<wbr><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><byte[],<wbr><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/wal/WALSplitter.html#line-107">regionMaxSeqIdInStores</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="fileBeingSplit"> |
| <h3>fileBeingSplit</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">org.apache.hadoop.fs.FileStatus</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-110">fileBeingSplit</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="tmpDirName"> |
| <h3>tmpDirName</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/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/wal/WALSplitter.html#line-112">tmpDirName</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="WAL_SPLIT_TO_HFILE"> |
| <h3>WAL_SPLIT_TO_HFILE</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/wal/WALSplitter.html#line-117">WAL_SPLIT_TO_HFILE</a></span></div> |
| <div class="block">Split WAL directly to hfiles instead of into intermediary 'recovered.edits' files.</div> |
| <dl class="notes"> |
| <dt>See Also:</dt> |
| <dd> |
| <ul class="see-list"> |
| <li><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.wal.WALSplitter.WAL_SPLIT_TO_HFILE">Constant Field Values</a></li> |
| </ul> |
| </dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="DEFAULT_WAL_SPLIT_TO_HFILE"> |
| <h3>DEFAULT_WAL_SPLIT_TO_HFILE</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/wal/WALSplitter.html#line-118">DEFAULT_WAL_SPLIT_TO_HFILE</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.wal.WALSplitter.DEFAULT_WAL_SPLIT_TO_HFILE">Constant Field Values</a></li> |
| </ul> |
| </dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="SPLIT_WRITER_CREATION_BOUNDED"> |
| <h3>SPLIT_WRITER_CREATION_BOUNDED</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/wal/WALSplitter.html#line-126">SPLIT_WRITER_CREATION_BOUNDED</a></span></div> |
| <div class="block">True if we are to run with bounded amount of writers rather than let the count blossom. Default |
| is 'false'. Does not apply if you have set 'hbase.wal.split.to.hfile' as that is always |
| bounded. Only applies when you are doing recovery to 'recovered.edits' files (the old default). |
| Bounded writing tends to have higher throughput.</div> |
| <dl class="notes"> |
| <dt>See Also:</dt> |
| <dd> |
| <ul class="see-list"> |
| <li><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.wal.WALSplitter.SPLIT_WRITER_CREATION_BOUNDED">Constant Field Values</a></li> |
| </ul> |
| </dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="SPLIT_WAL_BUFFER_SIZE"> |
| <h3>SPLIT_WAL_BUFFER_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/wal/WALSplitter.html#line-128">SPLIT_WAL_BUFFER_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.wal.WALSplitter.SPLIT_WAL_BUFFER_SIZE">Constant Field Values</a></li> |
| </ul> |
| </dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="SPLIT_WAL_WRITER_THREADS"> |
| <h3>SPLIT_WAL_WRITER_THREADS</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/wal/WALSplitter.html#line-129">SPLIT_WAL_WRITER_THREADS</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.wal.WALSplitter.SPLIT_WAL_WRITER_THREADS">Constant Field Values</a></li> |
| </ul> |
| </dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="numWriterThreads"> |
| <h3>numWriterThreads</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type">int</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-132">numWriterThreads</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="bufferSize"> |
| <h3>bufferSize</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type">long</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-133">bufferSize</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="splitWriterCreationBounded"> |
| <h3>splitWriterCreationBounded</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type">boolean</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-134">splitWriterCreationBounded</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="hfile"> |
| <h3>hfile</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type">boolean</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-135">hfile</a></span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="skipErrors"> |
| <h3>skipErrors</h3> |
| <div class="member-signature"><span class="modifiers">private final</span> <span class="return-type">boolean</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-136">skipErrors</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.hbase.wal.WALFactory,org.apache.hadoop.conf.Configuration,org.apache.hadoop.fs.Path,org.apache.hadoop.fs.FileSystem,org.apache.hadoop.fs.Path,org.apache.hadoop.fs.FileSystem)"> |
| <h3>WALSplitter</h3> |
| <div class="member-signature"><span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-138">WALSplitter</a></span><wbr><span class="parameters">(<a href="WALFactory.html" title="class in org.apache.hadoop.hbase.wal">WALFactory</a> factory, |
| org.apache.hadoop.conf.Configuration conf, |
| org.apache.hadoop.fs.Path walRootDir, |
| org.apache.hadoop.fs.FileSystem walFS, |
| org.apache.hadoop.fs.Path rootDir, |
| org.apache.hadoop.fs.FileSystem rootFS)</span></div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="<init>(org.apache.hadoop.hbase.wal.WALFactory,org.apache.hadoop.conf.Configuration,org.apache.hadoop.fs.Path,org.apache.hadoop.fs.FileSystem,org.apache.hadoop.fs.Path,org.apache.hadoop.fs.FileSystem,org.apache.hadoop.hbase.regionserver.LastSequenceId,org.apache.hadoop.hbase.coordination.SplitLogWorkerCoordination,org.apache.hadoop.hbase.regionserver.RegionServerServices)"> |
| <h3>WALSplitter</h3> |
| <div class="member-signature"><span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-143">WALSplitter</a></span><wbr><span class="parameters">(<a href="WALFactory.html" title="class in org.apache.hadoop.hbase.wal">WALFactory</a> factory, |
| org.apache.hadoop.conf.Configuration conf, |
| org.apache.hadoop.fs.Path walRootDir, |
| org.apache.hadoop.fs.FileSystem walFS, |
| org.apache.hadoop.fs.Path rootDir, |
| org.apache.hadoop.fs.FileSystem rootFS, |
| <a href="../regionserver/LastSequenceId.html" title="interface in org.apache.hadoop.hbase.regionserver">LastSequenceId</a> idChecker, |
| <a href="../coordination/SplitLogWorkerCoordination.html" title="interface in org.apache.hadoop.hbase.coordination">SplitLogWorkerCoordination</a> splitLogWorkerCoordination, |
| <a href="../regionserver/RegionServerServices.html" title="interface in org.apache.hadoop.hbase.regionserver">RegionServerServices</a> rsServices)</span></div> |
| </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="getWalFactory()"> |
| <h3>getWalFactory</h3> |
| <div class="member-signature"><span class="return-type"><a href="WALFactory.html" title="class in org.apache.hadoop.hbase.wal">WALFactory</a></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-168">getWalFactory</a></span>()</div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="getFileBeingSplit()"> |
| <h3>getFileBeingSplit</h3> |
| <div class="member-signature"><span class="return-type">org.apache.hadoop.fs.FileStatus</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-172">getFileBeingSplit</a></span>()</div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="getTmpDirName()"> |
| <h3>getTmpDirName</h3> |
| <div class="member-signature"><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/wal/WALSplitter.html#line-176">getTmpDirName</a></span>()</div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="getRegionMaxSeqIdInStores()"> |
| <h3>getRegionMaxSeqIdInStores</h3> |
| <div class="member-signature"><span class="return-type"><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><<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>,<wbr><a href="https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/Map.html" title="class or interface in java.util" class="external-link">Map</a><byte[],<wbr><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/wal/WALSplitter.html#line-180">getRegionMaxSeqIdInStores</a></span>()</div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="splitLogFile(org.apache.hadoop.fs.Path,org.apache.hadoop.fs.FileStatus,org.apache.hadoop.fs.FileSystem,org.apache.hadoop.conf.Configuration,org.apache.hadoop.hbase.util.CancelableProgressable,org.apache.hadoop.hbase.regionserver.LastSequenceId,org.apache.hadoop.hbase.coordination.SplitLogWorkerCoordination,org.apache.hadoop.hbase.wal.WALFactory,org.apache.hadoop.hbase.regionserver.RegionServerServices)"> |
| <h3>splitLogFile</h3> |
| <div class="member-signature"><span class="modifiers">public static</span> <span class="return-type">boolean</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-189">splitLogFile</a></span><wbr><span class="parameters">(org.apache.hadoop.fs.Path walDir, |
| org.apache.hadoop.fs.FileStatus logfile, |
| org.apache.hadoop.fs.FileSystem walFS, |
| org.apache.hadoop.conf.Configuration conf, |
| <a href="../util/CancelableProgressable.html" title="interface in org.apache.hadoop.hbase.util">CancelableProgressable</a> reporter, |
| <a href="../regionserver/LastSequenceId.html" title="interface in org.apache.hadoop.hbase.regionserver">LastSequenceId</a> idChecker, |
| <a href="../coordination/SplitLogWorkerCoordination.html" title="interface in org.apache.hadoop.hbase.coordination">SplitLogWorkerCoordination</a> splitLogWorkerCoordination, |
| <a href="WALFactory.html" title="class in org.apache.hadoop.hbase.wal">WALFactory</a> factory, |
| <a href="../regionserver/RegionServerServices.html" title="interface in org.apache.hadoop.hbase.regionserver">RegionServerServices</a> rsServices)</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> |
| <div class="block">Splits a WAL file. Used by old <a href="../regionserver/SplitLogWorker.html" title="class in org.apache.hadoop.hbase.regionserver"><code>SplitLogWorker</code></a> and |
| tests. Not used by new procedure-based WAL splitter.</div> |
| <dl class="notes"> |
| <dt>Returns:</dt> |
| <dd>false if it is interrupted by the progress-able.</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="split(org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path,org.apache.hadoop.fs.FileSystem,org.apache.hadoop.conf.Configuration,org.apache.hadoop.hbase.wal.WALFactory)"> |
| <h3>split</h3> |
| <div class="member-signature"><span class="modifiers">public static</span> <span class="return-type"><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><org.apache.hadoop.fs.Path></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-209">split</a></span><wbr><span class="parameters">(org.apache.hadoop.fs.Path walRootDir, |
| org.apache.hadoop.fs.Path walsDir, |
| org.apache.hadoop.fs.Path archiveDir, |
| org.apache.hadoop.fs.FileSystem walFS, |
| org.apache.hadoop.conf.Configuration conf, |
| <a href="WALFactory.html" title="class in org.apache.hadoop.hbase.wal">WALFactory</a> factory)</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> |
| <div class="block">Split a folder of WAL files. Delete the directory when done. Used by tools and unit tests. It |
| should be package private. It is public only because TestWALObserver is in a different package, |
| which uses this method to do log splitting.</div> |
| <dl class="notes"> |
| <dt>Returns:</dt> |
| <dd>List of output files created by the split.</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="createOutputSinkAndEntryBuffers()"> |
| <h3>createOutputSinkAndEntryBuffers</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">void</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-259">createOutputSinkAndEntryBuffers</a></span>()</div> |
| <div class="block">Setup the output sinks and entry buffers ahead of splitting WAL.</div> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="splitWAL(org.apache.hadoop.fs.FileStatus,org.apache.hadoop.hbase.util.CancelableProgressable)"> |
| <h3>splitWAL</h3> |
| <div class="member-signature"><span class="return-type"><a href="WALSplitter.SplitWALResult.html" title="class in org.apache.hadoop.hbase.wal">WALSplitter.SplitWALResult</a></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-280">splitWAL</a></span><wbr><span class="parameters">(org.apache.hadoop.fs.FileStatus walStatus, |
| <a href="../util/CancelableProgressable.html" title="interface in org.apache.hadoop.hbase.util">CancelableProgressable</a> cancel)</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> |
| <div class="block">WAL splitting implementation, splits one WAL file.</div> |
| <dl class="notes"> |
| <dt>Parameters:</dt> |
| <dd><code>walStatus</code> - should be for an actual WAL file.</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="isRegionDirPresentUnderRoot(org.apache.hadoop.hbase.TableName,java.lang.String)"> |
| <h3>isRegionDirPresentUnderRoot</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">boolean</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-435">isRegionDirPresentUnderRoot</a></span><wbr><span class="parameters">(<a href="../TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tn, |
| <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> region)</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="getReader(org.apache.hadoop.fs.FileStatus,boolean,org.apache.hadoop.hbase.util.CancelableProgressable)"> |
| <h3>getReader</h3> |
| <div class="member-signature"><span class="modifiers">protected</span> <span class="return-type"><a href="WALStreamReader.html" title="interface in org.apache.hadoop.hbase.wal">WALStreamReader</a></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-443">getReader</a></span><wbr><span class="parameters">(org.apache.hadoop.fs.FileStatus walStatus, |
| boolean skipErrors, |
| <a href="../util/CancelableProgressable.html" title="interface in org.apache.hadoop.hbase.util">CancelableProgressable</a> cancel)</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>, |
| <a href="WALSplitter.CorruptedLogFileException.html" title="class in org.apache.hadoop.hbase.wal">WALSplitter.CorruptedLogFileException</a></span></div> |
| <div class="block">Create a new <a href="WALStreamReader.html" title="interface in org.apache.hadoop.hbase.wal"><code>WALStreamReader</code></a> for reading logs to split.</div> |
| <dl class="notes"> |
| <dt>Returns:</dt> |
| <dd>Returns null if file has length zero or file can't be found.</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> |
| <dd><code><a href="WALSplitter.CorruptedLogFileException.html" title="class in org.apache.hadoop.hbase.wal">WALSplitter.CorruptedLogFileException</a></code></dd> |
| </dl> |
| </section> |
| </li> |
| <li> |
| <section class="detail" id="getNextLogLine(org.apache.hadoop.hbase.wal.WALStreamReader,org.apache.hadoop.fs.Path,boolean)"> |
| <h3>getNextLogLine</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type"><a href="WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-487">getNextLogLine</a></span><wbr><span class="parameters">(<a href="WALStreamReader.html" title="interface in org.apache.hadoop.hbase.wal">WALStreamReader</a> in, |
| org.apache.hadoop.fs.Path path, |
| boolean skipErrors)</span> |
| throws <span class="exceptions"><a href="WALSplitter.CorruptedLogFileException.html" title="class in org.apache.hadoop.hbase.wal">WALSplitter.CorruptedLogFileException</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="WALSplitter.CorruptedLogFileException.html" title="class in org.apache.hadoop.hbase.wal">WALSplitter.CorruptedLogFileException</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> |
| <li> |
| <section class="detail" id="createWriter(org.apache.hadoop.fs.Path)"> |
| <h3>createWriter</h3> |
| <div class="member-signature"><span class="modifiers">protected</span> <span class="return-type"><a href="WALProvider.Writer.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.Writer</a></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-517">createWriter</a></span><wbr><span class="parameters">(org.apache.hadoop.fs.Path logfile)</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> |
| <div class="block">Create a new <a href="WALProvider.Writer.html" title="interface in org.apache.hadoop.hbase.wal"><code>WALProvider.Writer</code></a> for writing log splits.</div> |
| <dl class="notes"> |
| <dt>Returns:</dt> |
| <dd>a new Writer instance, caller should close</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="getReader(org.apache.hadoop.fs.Path,org.apache.hadoop.hbase.util.CancelableProgressable)"> |
| <h3>getReader</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type"><a href="WALStreamReader.html" title="interface in org.apache.hadoop.hbase.wal">WALStreamReader</a></span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-525">getReader</a></span><wbr><span class="parameters">(org.apache.hadoop.fs.Path curLogFile, |
| <a href="../util/CancelableProgressable.html" title="interface in org.apache.hadoop.hbase.util">CancelableProgressable</a> reporter)</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> |
| <div class="block">Create a new <a href="WALStreamReader.html" title="interface in org.apache.hadoop.hbase.wal"><code>WALStreamReader</code></a> for reading logs to split.</div> |
| <dl class="notes"> |
| <dt>Returns:</dt> |
| <dd>new Reader instance, caller should close</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="getNumOpenWriters()"> |
| <h3>getNumOpenWriters</h3> |
| <div class="member-signature"><span class="modifiers">private</span> <span class="return-type">int</span> <span class="element-name"><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line-533">getNumOpenWriters</a></span>()</div> |
| <div class="block">Get current open writers</div> |
| </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> |