http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b248f175/devapidocs/org/apache/hadoop/hbase/wal/WALSplitter.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/wal/WALSplitter.html b/devapidocs/org/apache/hadoop/hbase/wal/WALSplitter.html index 6e49a29..6042f21 100644 --- a/devapidocs/org/apache/hadoop/hbase/wal/WALSplitter.html +++ b/devapidocs/org/apache/hadoop/hbase/wal/WALSplitter.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":9,"i1":10,"i2":9,"i3":9,"i4":9,"i5":9,"i6":9,"i7":9,"i8":9,"i9":9,"i10":10,"i11":10,"i12":10,"i13":9,"i14":9,"i15":9,"i16":9,"i17":9,"i18":9,"i19":9,"i20":9,"i21":10,"i22":9,"i23":9}; +var methods = {"i0":9,"i1":10,"i2":9,"i3":9,"i4":9,"i5":9,"i6":9,"i7":9,"i8":9,"i9":9,"i10":10,"i11":10,"i12":10,"i13":9,"i14":9,"i15":9,"i16":9,"i17":9,"i18":9,"i19":9,"i20":9,"i21":9,"i22":10,"i23":9,"i24":9}; var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -110,7 +110,7 @@ var activeTableTab = "activeTableTab"; <hr> <br> <pre>@InterfaceAudience.Private -public class <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.111">WALSplitter</a> +public class <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.112">WALSplitter</a> extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a></pre> <div class="block">This class is responsible for splitting up a bunch of regionserver commit log files that are no longer being written to, into new files, one per region, for @@ -458,18 +458,26 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html </tr> <tr id="i18" class="altColor"> <td class="colFirst"><code>static boolean</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/wal/WALSplitter.html#hasRecoveredEdits-org.apache.hadoop.fs.FileSystem-org.apache.hadoop.conf.Configuration-org.apache.hadoop.hbase.client.RegionInfo-">hasRecoveredEdits</a></span>(org.apache.hadoop.fs.FileSystem fs, + org.apache.hadoop.conf.Configuration conf, + <a href="../../../../../org/apache/hadoop/hbase/client/RegionInfo.html" title="interface in org.apache.hadoop.hbase.client">RegionInfo</a> regionInfo)</code> +<div class="block">Check whether there is recovered.edits in the region dir</div> +</td> +</tr> +<tr id="i19" class="rowColor"> +<td class="colFirst"><code>static boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/wal/WALSplitter.html#isSequenceIdFile-org.apache.hadoop.fs.Path-">isSequenceIdFile</a></span>(org.apache.hadoop.fs.Path file)</code> <div class="block">Is the given file a region open sequence id file.</div> </td> </tr> -<tr id="i19" class="rowColor"> +<tr id="i20" class="altColor"> <td class="colFirst"><code>static org.apache.hadoop.fs.Path</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/wal/WALSplitter.html#moveAsideBadEditsFile-org.apache.hadoop.fs.FileSystem-org.apache.hadoop.fs.Path-">moveAsideBadEditsFile</a></span>(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path edits)</code> <div class="block">Move aside a bad edits file.</div> </td> </tr> -<tr id="i20" class="altColor"> +<tr id="i21" class="rowColor"> <td class="colFirst"><code>static <a href="https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.fs.Path></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/wal/WALSplitter.html#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-">split</a></span>(org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.fs.Path logDir, @@ -478,14 +486,14 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html org.apache.hadoop.conf.Configuration conf, <a href="../../../../../org/apache/hadoop/hbase/wal/WALFactory.html" title="class in org.apache.hadoop.hbase.wal">WALFactory</a> factory)</code> </td> </tr> -<tr id="i21" class="rowColor"> +<tr id="i22" class="altColor"> <td class="colFirst"><code>(package private) boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/wal/WALSplitter.html#splitLogFile-org.apache.hadoop.fs.FileStatus-org.apache.hadoop.hbase.util.CancelableProgressable-">splitLogFile</a></span>(org.apache.hadoop.fs.FileStatus logfile, <a href="../../../../../org/apache/hadoop/hbase/util/CancelableProgressable.html" title="interface in org.apache.hadoop.hbase.util">CancelableProgressable</a> reporter)</code> <div class="block">log splitting implementation, splits one log file.</div> </td> </tr> -<tr id="i22" class="altColor"> +<tr id="i23" class="rowColor"> <td class="colFirst"><code>static boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/wal/WALSplitter.html#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-">splitLogFile</a></span>(org.apache.hadoop.fs.Path walDir, org.apache.hadoop.fs.FileStatus logfile, @@ -498,7 +506,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <div class="block">Splits a WAL file into region's recovered-edits directory.</div> </td> </tr> -<tr id="i23" class="rowColor"> +<tr id="i24" class="altColor"> <td class="colFirst"><code>static void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/wal/WALSplitter.html#writeRegionSequenceIdFile-org.apache.hadoop.fs.FileSystem-org.apache.hadoop.fs.Path-long-">writeRegionSequenceIdFile</a></span>(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path regionDir, @@ -534,7 +542,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>LOG</h4> -<pre>private static final org.slf4j.Logger <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.112">LOG</a></pre> +<pre>private static final org.slf4j.Logger <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.113">LOG</a></pre> </li> </ul> <a name="SPLIT_SKIP_ERRORS_DEFAULT"> @@ -543,7 +551,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>SPLIT_SKIP_ERRORS_DEFAULT</h4> -<pre>public static final boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.115">SPLIT_SKIP_ERRORS_DEFAULT</a></pre> +<pre>public static final boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.116">SPLIT_SKIP_ERRORS_DEFAULT</a></pre> <div class="block">By default we retry errors in splitting, rather than skipping.</div> <dl> <dt><span class="seeLabel">See Also:</span></dt> @@ -557,7 +565,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>walDir</h4> -<pre>protected final org.apache.hadoop.fs.Path <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.118">walDir</a></pre> +<pre>protected final org.apache.hadoop.fs.Path <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.119">walDir</a></pre> </li> </ul> <a name="fs"> @@ -566,7 +574,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>fs</h4> -<pre>protected final org.apache.hadoop.fs.FileSystem <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.119">fs</a></pre> +<pre>protected final org.apache.hadoop.fs.FileSystem <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.120">fs</a></pre> </li> </ul> <a name="conf"> @@ -575,7 +583,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>conf</h4> -<pre>protected final org.apache.hadoop.conf.Configuration <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.120">conf</a></pre> +<pre>protected final org.apache.hadoop.conf.Configuration <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.121">conf</a></pre> </li> </ul> <a name="outputSink"> @@ -584,7 +592,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>outputSink</h4> -<pre><a href="../../../../../org/apache/hadoop/hbase/wal/WALSplitter.OutputSink.html" title="class in org.apache.hadoop.hbase.wal">WALSplitter.OutputSink</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.124">outputSink</a></pre> +<pre><a href="../../../../../org/apache/hadoop/hbase/wal/WALSplitter.OutputSink.html" title="class in org.apache.hadoop.hbase.wal">WALSplitter.OutputSink</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.125">outputSink</a></pre> </li> </ul> <a name="entryBuffers"> @@ -593,7 +601,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>entryBuffers</h4> -<pre>private <a href="../../../../../org/apache/hadoop/hbase/wal/WALSplitter.EntryBuffers.html" title="class in org.apache.hadoop.hbase.wal">WALSplitter.EntryBuffers</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.125">entryBuffers</a></pre> +<pre>private <a href="../../../../../org/apache/hadoop/hbase/wal/WALSplitter.EntryBuffers.html" title="class in org.apache.hadoop.hbase.wal">WALSplitter.EntryBuffers</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.126">entryBuffers</a></pre> </li> </ul> <a name="splitLogWorkerCoordination"> @@ -602,7 +610,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>splitLogWorkerCoordination</h4> -<pre>private <a href="../../../../../org/apache/hadoop/hbase/coordination/SplitLogWorkerCoordination.html" title="interface in org.apache.hadoop.hbase.coordination">SplitLogWorkerCoordination</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.127">splitLogWorkerCoordination</a></pre> +<pre>private <a href="../../../../../org/apache/hadoop/hbase/coordination/SplitLogWorkerCoordination.html" title="interface in org.apache.hadoop.hbase.coordination">SplitLogWorkerCoordination</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.128">splitLogWorkerCoordination</a></pre> </li> </ul> <a name="walFactory"> @@ -611,7 +619,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>walFactory</h4> -<pre>private final <a href="../../../../../org/apache/hadoop/hbase/wal/WALFactory.html" title="class in org.apache.hadoop.hbase.wal">WALFactory</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.128">walFactory</a></pre> +<pre>private final <a href="../../../../../org/apache/hadoop/hbase/wal/WALFactory.html" title="class in org.apache.hadoop.hbase.wal">WALFactory</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.129">walFactory</a></pre> </li> </ul> <a name="status"> @@ -620,7 +628,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>status</h4> -<pre>private <a href="../../../../../org/apache/hadoop/hbase/monitoring/MonitoredTask.html" title="interface in org.apache.hadoop.hbase.monitoring">MonitoredTask</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.130">status</a></pre> +<pre>private <a href="../../../../../org/apache/hadoop/hbase/monitoring/MonitoredTask.html" title="interface in org.apache.hadoop.hbase.monitoring">MonitoredTask</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.131">status</a></pre> </li> </ul> <a name="sequenceIdChecker"> @@ -629,7 +637,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>sequenceIdChecker</h4> -<pre>protected final <a href="../../../../../org/apache/hadoop/hbase/regionserver/LastSequenceId.html" title="interface in org.apache.hadoop.hbase.regionserver">LastSequenceId</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.133">sequenceIdChecker</a></pre> +<pre>protected final <a href="../../../../../org/apache/hadoop/hbase/regionserver/LastSequenceId.html" title="interface in org.apache.hadoop.hbase.regionserver">LastSequenceId</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.134">sequenceIdChecker</a></pre> </li> </ul> <a name="lastFlushedSequenceIds"> @@ -638,7 +646,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>lastFlushedSequenceIds</h4> -<pre>protected <a href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.136">lastFlushedSequenceIds</a></pre> +<pre>protected <a href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.137">lastFlushedSequenceIds</a></pre> </li> </ul> <a name="regionMaxSeqIdInStores"> @@ -647,7 +655,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>regionMaxSeqIdInStores</h4> -<pre>protected <a href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><byte[],<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</a>>> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.139">regionMaxSeqIdInStores</a></pre> +<pre>protected <a href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><byte[],<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</a>>> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.140">regionMaxSeqIdInStores</a></pre> </li> </ul> <a name="fileBeingSplit"> @@ -656,7 +664,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>fileBeingSplit</h4> -<pre>private org.apache.hadoop.fs.FileStatus <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.142">fileBeingSplit</a></pre> +<pre>private org.apache.hadoop.fs.FileStatus <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.143">fileBeingSplit</a></pre> </li> </ul> <a name="splitWriterCreationBounded"> @@ -665,7 +673,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>splitWriterCreationBounded</h4> -<pre>private final boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.145">splitWriterCreationBounded</a></pre> +<pre>private final boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.146">splitWriterCreationBounded</a></pre> </li> </ul> <a name="SPLIT_WRITER_CREATION_BOUNDED"> @@ -674,7 +682,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>SPLIT_WRITER_CREATION_BOUNDED</h4> -<pre>public static final <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.147">SPLIT_WRITER_CREATION_BOUNDED</a></pre> +<pre>public static final <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.148">SPLIT_WRITER_CREATION_BOUNDED</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.wal.WALSplitter.SPLIT_WRITER_CREATION_BOUNDED">Constant Field Values</a></dd> @@ -687,7 +695,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>EDITFILES_NAME_PATTERN</h4> -<pre>private static final <a href="https://docs.oracle.com/javase/8/docs/api/java/util/regex/Pattern.html?is-external=true"; title="class or interface in java.util.regex">Pattern</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.533">EDITFILES_NAME_PATTERN</a></pre> +<pre>private static final <a href="https://docs.oracle.com/javase/8/docs/api/java/util/regex/Pattern.html?is-external=true"; title="class or interface in java.util.regex">Pattern</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.534">EDITFILES_NAME_PATTERN</a></pre> </li> </ul> <a name="RECOVERED_LOG_TMPFILE_SUFFIX"> @@ -696,7 +704,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>RECOVERED_LOG_TMPFILE_SUFFIX</h4> -<pre>private static final <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.534">RECOVERED_LOG_TMPFILE_SUFFIX</a></pre> +<pre>private static final <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.535">RECOVERED_LOG_TMPFILE_SUFFIX</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.wal.WALSplitter.RECOVERED_LOG_TMPFILE_SUFFIX">Constant Field Values</a></dd> @@ -709,7 +717,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>SEQUENCE_ID_FILE_SUFFIX</h4> -<pre>private static final <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.613">SEQUENCE_ID_FILE_SUFFIX</a></pre> +<pre>private static final <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.637">SEQUENCE_ID_FILE_SUFFIX</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.wal.WALSplitter.SEQUENCE_ID_FILE_SUFFIX">Constant Field Values</a></dd> @@ -722,7 +730,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>OLD_SEQUENCE_ID_FILE_SUFFIX</h4> -<pre>private static final <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.614">OLD_SEQUENCE_ID_FILE_SUFFIX</a></pre> +<pre>private static final <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.638">OLD_SEQUENCE_ID_FILE_SUFFIX</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.wal.WALSplitter.OLD_SEQUENCE_ID_FILE_SUFFIX">Constant Field Values</a></dd> @@ -735,7 +743,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockListLast"> <li class="blockList"> <h4>SEQUENCE_ID_FILE_SUFFIX_LENGTH</h4> -<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.615">SEQUENCE_ID_FILE_SUFFIX_LENGTH</a></pre> +<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.639">SEQUENCE_ID_FILE_SUFFIX_LENGTH</a></pre> </li> </ul> </li> @@ -752,7 +760,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockListLast"> <li class="blockList"> <h4>WALSplitter</h4> -<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.151">WALSplitter</a>(<a href="../../../../../org/apache/hadoop/hbase/wal/WALFactory.html" title="class in org.apache.hadoop.hbase.wal">WALFactory</a> factory, +<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.152">WALSplitter</a>(<a href="../../../../../org/apache/hadoop/hbase/wal/WALFactory.html" title="class in org.apache.hadoop.hbase.wal">WALFactory</a> factory, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path walDir, org.apache.hadoop.fs.FileSystem fs, @@ -774,7 +782,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>splitLogFile</h4> -<pre>public static boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.189">splitLogFile</a>(org.apache.hadoop.fs.Path walDir, +<pre>public static boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.190">splitLogFile</a>(org.apache.hadoop.fs.Path walDir, org.apache.hadoop.fs.FileStatus logfile, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf, @@ -802,7 +810,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>split</h4> -<pre>public static <a href="https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.fs.Path> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.203">split</a>(org.apache.hadoop.fs.Path rootDir, +<pre>public static <a href="https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.fs.Path> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.204">split</a>(org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.fs.Path logDir, org.apache.hadoop.fs.Path oldLogDir, org.apache.hadoop.fs.FileSystem fs, @@ -821,7 +829,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>splitLogFile</h4> -<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.230">splitLogFile</a>(org.apache.hadoop.fs.FileStatus logfile, +<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.231">splitLogFile</a>(org.apache.hadoop.fs.FileStatus logfile, <a href="../../../../../org/apache/hadoop/hbase/util/CancelableProgressable.html" title="interface in org.apache.hadoop.hbase.util">CancelableProgressable</a> reporter) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <div class="block">log splitting implementation, splits one log file.</div> @@ -839,7 +847,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>finishSplitLogFile</h4> -<pre>public static void <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.374">finishSplitLogFile</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> logfile, +<pre>public static void <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.375">finishSplitLogFile</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> logfile, org.apache.hadoop.conf.Configuration conf) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <div class="block">Completes the work done by splitLogFile by archiving logs @@ -863,7 +871,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>finishSplitLogFile</h4> -<pre>private static void <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.387">finishSplitLogFile</a>(org.apache.hadoop.fs.Path rootdir, +<pre>private static void <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.388">finishSplitLogFile</a>(org.apache.hadoop.fs.Path rootdir, org.apache.hadoop.fs.Path oldLogDir, org.apache.hadoop.fs.Path logPath, org.apache.hadoop.conf.Configuration conf) @@ -880,7 +888,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>archiveLogs</h4> -<pre>private static void <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.415">archiveLogs</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.fs.Path> corruptedLogs, +<pre>private static void <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.416">archiveLogs</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.fs.Path> corruptedLogs, <a href="https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.fs.Path> processedLogs, org.apache.hadoop.fs.Path oldLogDir, org.apache.hadoop.fs.FileSystem fs, @@ -907,7 +915,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>getRegionSplitEditsPath</h4> -<pre>static org.apache.hadoop.fs.Path <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.468">getRegionSplitEditsPath</a>(<a href="../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> logEntry, +<pre>static org.apache.hadoop.fs.Path <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.469">getRegionSplitEditsPath</a>(<a href="../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> logEntry, <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> fileNameBeingSplit, org.apache.hadoop.conf.Configuration conf) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> @@ -934,7 +942,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>getTmpRecoveredEditsFileName</h4> -<pre>private static <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.510">getTmpRecoveredEditsFileName</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> fileName)</pre> +<pre>private static <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.511">getTmpRecoveredEditsFileName</a>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> fileName)</pre> </li> </ul> <a name="getCompletedRecoveredEditsFilePath-org.apache.hadoop.fs.Path-long-"> @@ -943,7 +951,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>getCompletedRecoveredEditsFilePath</h4> -<pre>private static org.apache.hadoop.fs.Path <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.522">getCompletedRecoveredEditsFilePath</a>(org.apache.hadoop.fs.Path srcPath, +<pre>private static org.apache.hadoop.fs.Path <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.523">getCompletedRecoveredEditsFilePath</a>(org.apache.hadoop.fs.Path srcPath, long maximumEditLogSeqNum)</pre> <div class="block">Get the completed recovered edits file path, renaming it to be by last edit in the file from its first edit. Then we could use the name to skip @@ -963,7 +971,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>formatRecoveredEditsFileName</h4> -<pre>static <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.529">formatRecoveredEditsFileName</a>(long seqid)</pre> +<pre>static <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.530">formatRecoveredEditsFileName</a>(long seqid)</pre> </li> </ul> <a name="getRegionDirRecoveredEditsDir-org.apache.hadoop.fs.Path-"> @@ -972,7 +980,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>getRegionDirRecoveredEditsDir</h4> -<pre>public static org.apache.hadoop.fs.Path <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.542">getRegionDirRecoveredEditsDir</a>(org.apache.hadoop.fs.Path regiondir)</pre> +<pre>public static org.apache.hadoop.fs.Path <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.543">getRegionDirRecoveredEditsDir</a>(org.apache.hadoop.fs.Path regiondir)</pre> <dl> <dt><span class="paramLabel">Parameters:</span></dt> <dd><code>regiondir</code> - This regions directory in the filesystem.</dd> @@ -982,13 +990,36 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html </dl> </li> </ul> +<a name="hasRecoveredEdits-org.apache.hadoop.fs.FileSystem-org.apache.hadoop.conf.Configuration-org.apache.hadoop.hbase.client.RegionInfo-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>hasRecoveredEdits</h4> +<pre>public static boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.555">hasRecoveredEdits</a>(org.apache.hadoop.fs.FileSystem fs, + org.apache.hadoop.conf.Configuration conf, + <a href="../../../../../org/apache/hadoop/hbase/client/RegionInfo.html" title="interface in org.apache.hadoop.hbase.client">RegionInfo</a> regionInfo) + throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> +<div class="block">Check whether there is recovered.edits in the region dir</div> +<dl> +<dt><span class="paramLabel">Parameters:</span></dt> +<dd><code>fs</code> - FileSystem</dd> +<dd><code>conf</code> - conf</dd> +<dd><code>regionInfo</code> - the region to check</dd> +<dt><span class="returnLabel">Returns:</span></dt> +<dd>true if recovered.edits exist in the region dir</dd> +<dt><span class="throwsLabel">Throws:</span></dt> +<dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code> - IOException</dd> +</dl> +</li> +</ul> <a name="getSplitEditFilesSorted-org.apache.hadoop.fs.FileSystem-org.apache.hadoop.fs.Path-"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>getSplitEditFilesSorted</h4> -<pre>public static <a href="https://docs.oracle.com/javase/8/docs/api/java/util/NavigableSet.html?is-external=true"; title="class or interface in java.util">NavigableSet</a><org.apache.hadoop.fs.Path> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.555">getSplitEditFilesSorted</a>(org.apache.hadoop.fs.FileSystem fs, +<pre>public static <a href="https://docs.oracle.com/javase/8/docs/api/java/util/NavigableSet.html?is-external=true"; title="class or interface in java.util">NavigableSet</a><org.apache.hadoop.fs.Path> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.579">getSplitEditFilesSorted</a>(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path regiondir) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <div class="block">Returns sorted set of edit files made by splitter, excluding files @@ -1010,7 +1041,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>moveAsideBadEditsFile</h4> -<pre>public static org.apache.hadoop.fs.Path <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.603">moveAsideBadEditsFile</a>(org.apache.hadoop.fs.FileSystem fs, +<pre>public static org.apache.hadoop.fs.Path <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.627">moveAsideBadEditsFile</a>(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path edits) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <div class="block">Move aside a bad edits file.</div> @@ -1031,7 +1062,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>isSequenceIdFile</h4> -<pre>public static boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.621">isSequenceIdFile</a>(org.apache.hadoop.fs.Path file)</pre> +<pre>public static boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.645">isSequenceIdFile</a>(org.apache.hadoop.fs.Path file)</pre> <div class="block">Is the given file a region open sequence id file.</div> </li> </ul> @@ -1041,7 +1072,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>getSequenceIdFiles</h4> -<pre>private static org.apache.hadoop.fs.FileStatus[] <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.626">getSequenceIdFiles</a>(org.apache.hadoop.fs.FileSystem fs, +<pre>private static org.apache.hadoop.fs.FileStatus[] <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.650">getSequenceIdFiles</a>(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path regionDir) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl> @@ -1056,7 +1087,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>getMaxSequenceId</h4> -<pre>private static long <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.638">getMaxSequenceId</a>(org.apache.hadoop.fs.FileStatus[] files)</pre> +<pre>private static long <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.662">getMaxSequenceId</a>(org.apache.hadoop.fs.FileStatus[] files)</pre> </li> </ul> <a name="getMaxRegionSequenceId-org.apache.hadoop.fs.FileSystem-org.apache.hadoop.fs.Path-"> @@ -1065,7 +1096,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>getMaxRegionSequenceId</h4> -<pre>public static long <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.655">getMaxRegionSequenceId</a>(org.apache.hadoop.fs.FileSystem fs, +<pre>public static long <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.679">getMaxRegionSequenceId</a>(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path regionDir) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <div class="block">Get the max sequence id which is stored in the region directory. -1 if none.</div> @@ -1081,7 +1112,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>writeRegionSequenceIdFile</h4> -<pre>public static void <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.662">writeRegionSequenceIdFile</a>(org.apache.hadoop.fs.FileSystem fs, +<pre>public static void <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.686">writeRegionSequenceIdFile</a>(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path regionDir, long newMaxSeqId) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> @@ -1098,7 +1129,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>getReader</h4> -<pre>protected <a href="../../../../../org/apache/hadoop/hbase/wal/WAL.Reader.html" title="interface in org.apache.hadoop.hbase.wal">WAL.Reader</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.700">getReader</a>(org.apache.hadoop.fs.FileStatus file, +<pre>protected <a href="../../../../../org/apache/hadoop/hbase/wal/WAL.Reader.html" title="interface in org.apache.hadoop.hbase.wal">WAL.Reader</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.724">getReader</a>(org.apache.hadoop.fs.FileStatus file, boolean skipErrors, <a href="../../../../../org/apache/hadoop/hbase/util/CancelableProgressable.html" title="interface in org.apache.hadoop.hbase.util">CancelableProgressable</a> reporter) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a>, @@ -1121,7 +1152,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>getNextLogLine</h4> -<pre>private static <a href="../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.747">getNextLogLine</a>(<a href="../../../../../org/apache/hadoop/hbase/wal/WAL.Reader.html" title="interface in org.apache.hadoop.hbase.wal">WAL.Reader</a> in, +<pre>private static <a href="../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html" title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.771">getNextLogLine</a>(<a href="../../../../../org/apache/hadoop/hbase/wal/WAL.Reader.html" title="interface in org.apache.hadoop.hbase.wal">WAL.Reader</a> in, org.apache.hadoop.fs.Path path, boolean skipErrors) throws <a href="../../../../../org/apache/hadoop/hbase/wal/WALSplitter.CorruptedLogFileException.html" title="class in org.apache.hadoop.hbase.wal">WALSplitter.CorruptedLogFileException</a>, @@ -1139,7 +1170,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>createWriter</h4> -<pre>protected <a href="../../../../../org/apache/hadoop/hbase/wal/WALProvider.Writer.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.Writer</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.779">createWriter</a>(org.apache.hadoop.fs.Path logfile) +<pre>protected <a href="../../../../../org/apache/hadoop/hbase/wal/WALProvider.Writer.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.Writer</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.803">createWriter</a>(org.apache.hadoop.fs.Path logfile) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <div class="block">Create a new <a href="../../../../../org/apache/hadoop/hbase/wal/WALProvider.Writer.html" title="interface in org.apache.hadoop.hbase.wal"><code>WALProvider.Writer</code></a> for writing log splits.</div> <dl> @@ -1156,7 +1187,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>getReader</h4> -<pre>protected <a href="../../../../../org/apache/hadoop/hbase/wal/WAL.Reader.html" title="interface in org.apache.hadoop.hbase.wal">WAL.Reader</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.788">getReader</a>(org.apache.hadoop.fs.Path curLogFile, +<pre>protected <a href="../../../../../org/apache/hadoop/hbase/wal/WAL.Reader.html" title="interface in org.apache.hadoop.hbase.wal">WAL.Reader</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.812">getReader</a>(org.apache.hadoop.fs.Path curLogFile, <a href="../../../../../org/apache/hadoop/hbase/util/CancelableProgressable.html" title="interface in org.apache.hadoop.hbase.util">CancelableProgressable</a> reporter) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <div class="block">Create a new <a href="../../../../../org/apache/hadoop/hbase/wal/WAL.Reader.html" title="interface in org.apache.hadoop.hbase.wal"><code>WAL.Reader</code></a> for reading logs to split.</div> @@ -1174,7 +1205,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockList"> <li class="blockList"> <h4>getNumOpenWriters</h4> -<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.795">getNumOpenWriters</a>()</pre> +<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.819">getNumOpenWriters</a>()</pre> <div class="block">Get current open writers</div> </li> </ul> @@ -1184,7 +1215,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockListLast"> <li class="blockList"> <h4>getMutationsFromWALEntry</h4> -<pre>public static <a href="https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../org/apache/hadoop/hbase/wal/WALSplitter.MutationReplay.html" title="class in org.apache.hadoop.hbase.wal">WALSplitter.MutationReplay</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.1823">getMutationsFromWALEntry</a>(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry entry, +<pre>public static <a href="https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../org/apache/hadoop/hbase/wal/WALSplitter.MutationReplay.html" title="class in org.apache.hadoop.hbase.wal">WALSplitter.MutationReplay</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/wal/WALSplitter.html#line.1847">getMutationsFromWALEntry</a>(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry entry, <a href="../../../../../org/apache/hadoop/hbase/CellScanner.html" title="interface in org.apache.hadoop.hbase">CellScanner</a> cells, <a href="../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><<a href="../../../../../org/apache/hadoop/hbase/wal/WALKey.html" title="interface in org.apache.hadoop.hbase.wal">WALKey</a>,<a href="../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a>> logEntry, <a href="../../../../../org/apache/hadoop/hbase/client/Durability.html" title="enum in org.apache.hadoop.hbase.client">Durability</a> durability)
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b248f175/devapidocs/org/apache/hadoop/hbase/wal/package-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/wal/package-tree.html b/devapidocs/org/apache/hadoop/hbase/wal/package-tree.html index c6caa9b..bcb1724 100644 --- a/devapidocs/org/apache/hadoop/hbase/wal/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/wal/package-tree.html @@ -191,8 +191,8 @@ <ul> <li type="circle">java.lang.<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true"; title="class or interface in java.lang"><span class="typeNameLink">Enum</span></a><E> (implements java.lang.<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true"; title="class or interface in java.lang">Comparable</a><T>, java.io.<a href="https://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true"; title="class or interface in java.io">Serializable</a>) <ul> -<li type="circle">org.apache.hadoop.hbase.wal.<a href="../../../../../org/apache/hadoop/hbase/wal/WALFactory.Providers.html" title="enum in org.apache.hadoop.hbase.wal"><span class="typeNameLink">WALFactory.Providers</span></a></li> <li type="circle">org.apache.hadoop.hbase.wal.<a href="../../../../../org/apache/hadoop/hbase/wal/RegionGroupingProvider.Strategies.html" title="enum in org.apache.hadoop.hbase.wal"><span class="typeNameLink">RegionGroupingProvider.Strategies</span></a></li> +<li type="circle">org.apache.hadoop.hbase.wal.<a href="../../../../../org/apache/hadoop/hbase/wal/WALFactory.Providers.html" title="enum in org.apache.hadoop.hbase.wal"><span class="typeNameLink">WALFactory.Providers</span></a></li> </ul> </li> </ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b248f175/devapidocs/src-html/org/apache/hadoop/hbase/Version.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/Version.html b/devapidocs/src-html/org/apache/hadoop/hbase/Version.html index e44cfd7..97ab6a0 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/Version.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/Version.html @@ -16,11 +16,11 @@ <span class="sourceLineNo">008</span>@InterfaceAudience.Private<a name="line.8"></a> <span class="sourceLineNo">009</span>public class Version {<a name="line.9"></a> <span class="sourceLineNo">010</span> public static final String version = "3.0.0-SNAPSHOT";<a name="line.10"></a> -<span class="sourceLineNo">011</span> public static final String revision = "b4759ce6e72f50ccd9d410bd5917dc5a515414f1";<a name="line.11"></a> +<span class="sourceLineNo">011</span> public static final String revision = "4804483f7e55edf91a8e9d7ad30ad8239a96eaf3";<a name="line.11"></a> <span class="sourceLineNo">012</span> public static final String user = "jenkins";<a name="line.12"></a> -<span class="sourceLineNo">013</span> public static final String date = "Sun Jul 22 09:20:24 UTC 2018";<a name="line.13"></a> +<span class="sourceLineNo">013</span> public static final String date = "Mon Jul 23 14:39:55 UTC 2018";<a name="line.13"></a> <span class="sourceLineNo">014</span> public static final String url = "git://jenkins-websites1.apache.org/home/jenkins/jenkins-slave/workspace/hbase_generate_website/hbase";<a name="line.14"></a> -<span class="sourceLineNo">015</span> public static final String srcChecksum = "3449ee861188a2ccacfbd7a165550672";<a name="line.15"></a> +<span class="sourceLineNo">015</span> public static final String srcChecksum = "ff61797fa6fbedfa31d17ed25b27b2c0";<a name="line.15"></a> <span class="sourceLineNo">016</span>}<a name="line.16"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b248f175/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MetaTableMetrics.ExampleRegionObserverMeta.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MetaTableMetrics.ExampleRegionObserverMeta.html b/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MetaTableMetrics.ExampleRegionObserverMeta.html index c4e9511..632b102 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MetaTableMetrics.ExampleRegionObserverMeta.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MetaTableMetrics.ExampleRegionObserverMeta.html @@ -317,30 +317,31 @@ <span class="sourceLineNo">309</span> public void start(CoprocessorEnvironment env) throws IOException {<a name="line.309"></a> <span class="sourceLineNo">310</span> if (env instanceof RegionCoprocessorEnvironment<a name="line.310"></a> <span class="sourceLineNo">311</span> && ((RegionCoprocessorEnvironment) env).getRegionInfo().getTable() != null<a name="line.311"></a> -<span class="sourceLineNo">312</span> && ((RegionCoprocessorEnvironment) env).getRegionInfo().getTable().getName() != null<a name="line.312"></a> -<span class="sourceLineNo">313</span> && new String(((RegionCoprocessorEnvironment) env).getRegionInfo().getTable().getName(),<a name="line.313"></a> -<span class="sourceLineNo">314</span> StandardCharsets.UTF_8).equals(TableName.META_TABLE_NAME.toString())) {<a name="line.314"></a> -<span class="sourceLineNo">315</span> regionCoprocessorEnv = (RegionCoprocessorEnvironment) env;<a name="line.315"></a> -<span class="sourceLineNo">316</span> observer = new ExampleRegionObserverMeta();<a name="line.316"></a> -<span class="sourceLineNo">317</span> requestsMap = new ConcurrentHashMap<>();<a name="line.317"></a> -<span class="sourceLineNo">318</span> clientMetricsLossyCounting = new LossyCounting();<a name="line.318"></a> -<span class="sourceLineNo">319</span> // only be active mode when this region holds meta table.<a name="line.319"></a> -<span class="sourceLineNo">320</span> active = true;<a name="line.320"></a> -<span class="sourceLineNo">321</span> } else {<a name="line.321"></a> -<span class="sourceLineNo">322</span> observer = new ExampleRegionObserverMeta();<a name="line.322"></a> -<span class="sourceLineNo">323</span> }<a name="line.323"></a> -<span class="sourceLineNo">324</span> }<a name="line.324"></a> -<span class="sourceLineNo">325</span><a name="line.325"></a> -<span class="sourceLineNo">326</span> @Override<a name="line.326"></a> -<span class="sourceLineNo">327</span> public void stop(CoprocessorEnvironment e) throws IOException {<a name="line.327"></a> -<span class="sourceLineNo">328</span> // since meta region can move around, clear stale metrics when stop.<a name="line.328"></a> -<span class="sourceLineNo">329</span> for (String meterName : requestsMap.keySet()) {<a name="line.329"></a> -<span class="sourceLineNo">330</span> MetricRegistry registry = regionCoprocessorEnv.getMetricRegistryForRegionServer();<a name="line.330"></a> -<span class="sourceLineNo">331</span> registry.remove(meterName);<a name="line.331"></a> -<span class="sourceLineNo">332</span> }<a name="line.332"></a> -<span class="sourceLineNo">333</span> }<a name="line.333"></a> -<span class="sourceLineNo">334</span><a name="line.334"></a> -<span class="sourceLineNo">335</span>}<a name="line.335"></a> +<span class="sourceLineNo">312</span> && ((RegionCoprocessorEnvironment) env).getRegionInfo().getTable()<a name="line.312"></a> +<span class="sourceLineNo">313</span> .equals(TableName.META_TABLE_NAME)) {<a name="line.313"></a> +<span class="sourceLineNo">314</span> regionCoprocessorEnv = (RegionCoprocessorEnvironment) env;<a name="line.314"></a> +<span class="sourceLineNo">315</span> observer = new ExampleRegionObserverMeta();<a name="line.315"></a> +<span class="sourceLineNo">316</span> requestsMap = new ConcurrentHashMap<>();<a name="line.316"></a> +<span class="sourceLineNo">317</span> clientMetricsLossyCounting = new LossyCounting();<a name="line.317"></a> +<span class="sourceLineNo">318</span> // only be active mode when this region holds meta table.<a name="line.318"></a> +<span class="sourceLineNo">319</span> active = true;<a name="line.319"></a> +<span class="sourceLineNo">320</span> } else {<a name="line.320"></a> +<span class="sourceLineNo">321</span> observer = new ExampleRegionObserverMeta();<a name="line.321"></a> +<span class="sourceLineNo">322</span> }<a name="line.322"></a> +<span class="sourceLineNo">323</span> }<a name="line.323"></a> +<span class="sourceLineNo">324</span><a name="line.324"></a> +<span class="sourceLineNo">325</span> @Override<a name="line.325"></a> +<span class="sourceLineNo">326</span> public void stop(CoprocessorEnvironment env) throws IOException {<a name="line.326"></a> +<span class="sourceLineNo">327</span> // since meta region can move around, clear stale metrics when stop.<a name="line.327"></a> +<span class="sourceLineNo">328</span> if (requestsMap != null) {<a name="line.328"></a> +<span class="sourceLineNo">329</span> for (String meterName : requestsMap.keySet()) {<a name="line.329"></a> +<span class="sourceLineNo">330</span> MetricRegistry registry = regionCoprocessorEnv.getMetricRegistryForRegionServer();<a name="line.330"></a> +<span class="sourceLineNo">331</span> registry.remove(meterName);<a name="line.331"></a> +<span class="sourceLineNo">332</span> }<a name="line.332"></a> +<span class="sourceLineNo">333</span> }<a name="line.333"></a> +<span class="sourceLineNo">334</span> }<a name="line.334"></a> +<span class="sourceLineNo">335</span><a name="line.335"></a> +<span class="sourceLineNo">336</span>}<a name="line.336"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b248f175/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MetaTableMetrics.MetaTableOps.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MetaTableMetrics.MetaTableOps.html b/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MetaTableMetrics.MetaTableOps.html index c4e9511..632b102 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MetaTableMetrics.MetaTableOps.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MetaTableMetrics.MetaTableOps.html @@ -317,30 +317,31 @@ <span class="sourceLineNo">309</span> public void start(CoprocessorEnvironment env) throws IOException {<a name="line.309"></a> <span class="sourceLineNo">310</span> if (env instanceof RegionCoprocessorEnvironment<a name="line.310"></a> <span class="sourceLineNo">311</span> && ((RegionCoprocessorEnvironment) env).getRegionInfo().getTable() != null<a name="line.311"></a> -<span class="sourceLineNo">312</span> && ((RegionCoprocessorEnvironment) env).getRegionInfo().getTable().getName() != null<a name="line.312"></a> -<span class="sourceLineNo">313</span> && new String(((RegionCoprocessorEnvironment) env).getRegionInfo().getTable().getName(),<a name="line.313"></a> -<span class="sourceLineNo">314</span> StandardCharsets.UTF_8).equals(TableName.META_TABLE_NAME.toString())) {<a name="line.314"></a> -<span class="sourceLineNo">315</span> regionCoprocessorEnv = (RegionCoprocessorEnvironment) env;<a name="line.315"></a> -<span class="sourceLineNo">316</span> observer = new ExampleRegionObserverMeta();<a name="line.316"></a> -<span class="sourceLineNo">317</span> requestsMap = new ConcurrentHashMap<>();<a name="line.317"></a> -<span class="sourceLineNo">318</span> clientMetricsLossyCounting = new LossyCounting();<a name="line.318"></a> -<span class="sourceLineNo">319</span> // only be active mode when this region holds meta table.<a name="line.319"></a> -<span class="sourceLineNo">320</span> active = true;<a name="line.320"></a> -<span class="sourceLineNo">321</span> } else {<a name="line.321"></a> -<span class="sourceLineNo">322</span> observer = new ExampleRegionObserverMeta();<a name="line.322"></a> -<span class="sourceLineNo">323</span> }<a name="line.323"></a> -<span class="sourceLineNo">324</span> }<a name="line.324"></a> -<span class="sourceLineNo">325</span><a name="line.325"></a> -<span class="sourceLineNo">326</span> @Override<a name="line.326"></a> -<span class="sourceLineNo">327</span> public void stop(CoprocessorEnvironment e) throws IOException {<a name="line.327"></a> -<span class="sourceLineNo">328</span> // since meta region can move around, clear stale metrics when stop.<a name="line.328"></a> -<span class="sourceLineNo">329</span> for (String meterName : requestsMap.keySet()) {<a name="line.329"></a> -<span class="sourceLineNo">330</span> MetricRegistry registry = regionCoprocessorEnv.getMetricRegistryForRegionServer();<a name="line.330"></a> -<span class="sourceLineNo">331</span> registry.remove(meterName);<a name="line.331"></a> -<span class="sourceLineNo">332</span> }<a name="line.332"></a> -<span class="sourceLineNo">333</span> }<a name="line.333"></a> -<span class="sourceLineNo">334</span><a name="line.334"></a> -<span class="sourceLineNo">335</span>}<a name="line.335"></a> +<span class="sourceLineNo">312</span> && ((RegionCoprocessorEnvironment) env).getRegionInfo().getTable()<a name="line.312"></a> +<span class="sourceLineNo">313</span> .equals(TableName.META_TABLE_NAME)) {<a name="line.313"></a> +<span class="sourceLineNo">314</span> regionCoprocessorEnv = (RegionCoprocessorEnvironment) env;<a name="line.314"></a> +<span class="sourceLineNo">315</span> observer = new ExampleRegionObserverMeta();<a name="line.315"></a> +<span class="sourceLineNo">316</span> requestsMap = new ConcurrentHashMap<>();<a name="line.316"></a> +<span class="sourceLineNo">317</span> clientMetricsLossyCounting = new LossyCounting();<a name="line.317"></a> +<span class="sourceLineNo">318</span> // only be active mode when this region holds meta table.<a name="line.318"></a> +<span class="sourceLineNo">319</span> active = true;<a name="line.319"></a> +<span class="sourceLineNo">320</span> } else {<a name="line.320"></a> +<span class="sourceLineNo">321</span> observer = new ExampleRegionObserverMeta();<a name="line.321"></a> +<span class="sourceLineNo">322</span> }<a name="line.322"></a> +<span class="sourceLineNo">323</span> }<a name="line.323"></a> +<span class="sourceLineNo">324</span><a name="line.324"></a> +<span class="sourceLineNo">325</span> @Override<a name="line.325"></a> +<span class="sourceLineNo">326</span> public void stop(CoprocessorEnvironment env) throws IOException {<a name="line.326"></a> +<span class="sourceLineNo">327</span> // since meta region can move around, clear stale metrics when stop.<a name="line.327"></a> +<span class="sourceLineNo">328</span> if (requestsMap != null) {<a name="line.328"></a> +<span class="sourceLineNo">329</span> for (String meterName : requestsMap.keySet()) {<a name="line.329"></a> +<span class="sourceLineNo">330</span> MetricRegistry registry = regionCoprocessorEnv.getMetricRegistryForRegionServer();<a name="line.330"></a> +<span class="sourceLineNo">331</span> registry.remove(meterName);<a name="line.331"></a> +<span class="sourceLineNo">332</span> }<a name="line.332"></a> +<span class="sourceLineNo">333</span> }<a name="line.333"></a> +<span class="sourceLineNo">334</span> }<a name="line.334"></a> +<span class="sourceLineNo">335</span><a name="line.335"></a> +<span class="sourceLineNo">336</span>}<a name="line.336"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b248f175/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MetaTableMetrics.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MetaTableMetrics.html b/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MetaTableMetrics.html index c4e9511..632b102 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MetaTableMetrics.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MetaTableMetrics.html @@ -317,30 +317,31 @@ <span class="sourceLineNo">309</span> public void start(CoprocessorEnvironment env) throws IOException {<a name="line.309"></a> <span class="sourceLineNo">310</span> if (env instanceof RegionCoprocessorEnvironment<a name="line.310"></a> <span class="sourceLineNo">311</span> && ((RegionCoprocessorEnvironment) env).getRegionInfo().getTable() != null<a name="line.311"></a> -<span class="sourceLineNo">312</span> && ((RegionCoprocessorEnvironment) env).getRegionInfo().getTable().getName() != null<a name="line.312"></a> -<span class="sourceLineNo">313</span> && new String(((RegionCoprocessorEnvironment) env).getRegionInfo().getTable().getName(),<a name="line.313"></a> -<span class="sourceLineNo">314</span> StandardCharsets.UTF_8).equals(TableName.META_TABLE_NAME.toString())) {<a name="line.314"></a> -<span class="sourceLineNo">315</span> regionCoprocessorEnv = (RegionCoprocessorEnvironment) env;<a name="line.315"></a> -<span class="sourceLineNo">316</span> observer = new ExampleRegionObserverMeta();<a name="line.316"></a> -<span class="sourceLineNo">317</span> requestsMap = new ConcurrentHashMap<>();<a name="line.317"></a> -<span class="sourceLineNo">318</span> clientMetricsLossyCounting = new LossyCounting();<a name="line.318"></a> -<span class="sourceLineNo">319</span> // only be active mode when this region holds meta table.<a name="line.319"></a> -<span class="sourceLineNo">320</span> active = true;<a name="line.320"></a> -<span class="sourceLineNo">321</span> } else {<a name="line.321"></a> -<span class="sourceLineNo">322</span> observer = new ExampleRegionObserverMeta();<a name="line.322"></a> -<span class="sourceLineNo">323</span> }<a name="line.323"></a> -<span class="sourceLineNo">324</span> }<a name="line.324"></a> -<span class="sourceLineNo">325</span><a name="line.325"></a> -<span class="sourceLineNo">326</span> @Override<a name="line.326"></a> -<span class="sourceLineNo">327</span> public void stop(CoprocessorEnvironment e) throws IOException {<a name="line.327"></a> -<span class="sourceLineNo">328</span> // since meta region can move around, clear stale metrics when stop.<a name="line.328"></a> -<span class="sourceLineNo">329</span> for (String meterName : requestsMap.keySet()) {<a name="line.329"></a> -<span class="sourceLineNo">330</span> MetricRegistry registry = regionCoprocessorEnv.getMetricRegistryForRegionServer();<a name="line.330"></a> -<span class="sourceLineNo">331</span> registry.remove(meterName);<a name="line.331"></a> -<span class="sourceLineNo">332</span> }<a name="line.332"></a> -<span class="sourceLineNo">333</span> }<a name="line.333"></a> -<span class="sourceLineNo">334</span><a name="line.334"></a> -<span class="sourceLineNo">335</span>}<a name="line.335"></a> +<span class="sourceLineNo">312</span> && ((RegionCoprocessorEnvironment) env).getRegionInfo().getTable()<a name="line.312"></a> +<span class="sourceLineNo">313</span> .equals(TableName.META_TABLE_NAME)) {<a name="line.313"></a> +<span class="sourceLineNo">314</span> regionCoprocessorEnv = (RegionCoprocessorEnvironment) env;<a name="line.314"></a> +<span class="sourceLineNo">315</span> observer = new ExampleRegionObserverMeta();<a name="line.315"></a> +<span class="sourceLineNo">316</span> requestsMap = new ConcurrentHashMap<>();<a name="line.316"></a> +<span class="sourceLineNo">317</span> clientMetricsLossyCounting = new LossyCounting();<a name="line.317"></a> +<span class="sourceLineNo">318</span> // only be active mode when this region holds meta table.<a name="line.318"></a> +<span class="sourceLineNo">319</span> active = true;<a name="line.319"></a> +<span class="sourceLineNo">320</span> } else {<a name="line.320"></a> +<span class="sourceLineNo">321</span> observer = new ExampleRegionObserverMeta();<a name="line.321"></a> +<span class="sourceLineNo">322</span> }<a name="line.322"></a> +<span class="sourceLineNo">323</span> }<a name="line.323"></a> +<span class="sourceLineNo">324</span><a name="line.324"></a> +<span class="sourceLineNo">325</span> @Override<a name="line.325"></a> +<span class="sourceLineNo">326</span> public void stop(CoprocessorEnvironment env) throws IOException {<a name="line.326"></a> +<span class="sourceLineNo">327</span> // since meta region can move around, clear stale metrics when stop.<a name="line.327"></a> +<span class="sourceLineNo">328</span> if (requestsMap != null) {<a name="line.328"></a> +<span class="sourceLineNo">329</span> for (String meterName : requestsMap.keySet()) {<a name="line.329"></a> +<span class="sourceLineNo">330</span> MetricRegistry registry = regionCoprocessorEnv.getMetricRegistryForRegionServer();<a name="line.330"></a> +<span class="sourceLineNo">331</span> registry.remove(meterName);<a name="line.331"></a> +<span class="sourceLineNo">332</span> }<a name="line.332"></a> +<span class="sourceLineNo">333</span> }<a name="line.333"></a> +<span class="sourceLineNo">334</span> }<a name="line.334"></a> +<span class="sourceLineNo">335</span><a name="line.335"></a> +<span class="sourceLineNo">336</span>}<a name="line.336"></a>
