http://git-wip-us.apache.org/repos/asf/hbase-site/blob/7f23ee04/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html
----------------------------------------------------------------------
diff --git
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html
new file mode 100644
index 0000000..8a3ae32
--- /dev/null
+++
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html
@@ -0,0 +1,857 @@
+<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"
"http://www.w3.org/TR/html4/loose.dtd";>
+<!-- NewPage -->
+<html lang="en">
+<head>
+<!-- Generated by javadoc -->
+<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
+<title>ReplicationSourceWALReader (Apache HBase 3.0.0-SNAPSHOT API)</title>
+<link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css"
title="Style">
+<script type="text/javascript" src="../../../../../../script.js"></script>
+</head>
+<body>
+<script type="text/javascript"><!--
+ try {
+ if (location.href.indexOf('is-external=true') == -1) {
+ parent.document.title="ReplicationSourceWALReader (Apache HBase
3.0.0-SNAPSHOT API)";
+ }
+ }
+ catch(err) {
+ }
+//-->
+var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10};
+var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],8:["t4","Concrete Methods"]};
+var altColor = "altColor";
+var rowColor = "rowColor";
+var tableTab = "tableTab";
+var activeTableTab = "activeTableTab";
+</script>
+<noscript>
+<div>JavaScript is disabled on your browser.</div>
+</noscript>
+<!-- ========= START OF TOP NAVBAR ======= -->
+<div class="topNav"><a name="navbar.top">
+<!-- -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation
links">Skip navigation links</a></div>
+<a name="navbar.top.firstrow">
+<!-- -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../../../../overview-summary.html">Overview</a></li>
+<li><a href="package-summary.html">Package</a></li>
+<li class="navBarCell1Rev">Class</li>
+<li><a href="class-use/ReplicationSourceWALReader.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">Help</a></li>
+</ul>
+</div>
+<div class="subNav">
+<ul class="navList">
+<li><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html"
title="enum in org.apache.hadoop.hbase.replication.regionserver"><span
class="typeNameLink">Prev Class</span></a></li>
+<li><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.WALEntryBatch.html"
title="class in org.apache.hadoop.hbase.replication.regionserver"><span
class="typeNameLink">Next Class</span></a></li>
+</ul>
+<ul class="navList">
+<li><a
href="../../../../../../index.html?org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html"
target="_top">Frames</a></li>
+<li><a href="ReplicationSourceWALReader.html"
target="_top">No Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_top">
+<li><a
href="../../../../../../allclasses-noframe.html">All Classes</a></li>
+</ul>
+<div>
+<script type="text/javascript"><!--
+ allClassesLink = document.getElementById("allclasses_navbar_top");
+ if(window==top) {
+ allClassesLink.style.display = "block";
+ }
+ else {
+ allClassesLink.style.display = "none";
+ }
+ //-->
+</script>
+</div>
+<div>
+<ul class="subNavList">
+<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="subNavList">
+<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>
+<a name="skip.navbar.top">
+<!-- -->
+</a></div>
+<!-- ========= END OF TOP NAVBAR ========= -->
+<!-- ======== START OF CLASS DATA ======== -->
+<div class="header">
+<div class="subTitle">org.apache.hadoop.hbase.replication.regionserver</div>
+<h2 title="Class ReplicationSourceWALReader" class="title">Class
ReplicationSourceWALReader</h2>
+</div>
+<div class="contentContainer">
+<ul class="inheritance">
+<li><a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
title="class or interface in java.lang">java.lang.Object</a></li>
+<li>
+<ul class="inheritance">
+<li><a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true";
title="class or interface in java.lang">java.lang.Thread</a></li>
+<li>
+<ul class="inheritance">
+<li>org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader</li>
+</ul>
+</li>
+</ul>
+</li>
+</ul>
+<div class="description">
+<ul class="blockList">
+<li class="blockList">
+<dl>
+<dt>All Implemented Interfaces:</dt>
+<dd><a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true";
title="class or interface in java.lang">Runnable</a></dd>
+</dl>
+<dl>
+<dt>Direct Known Subclasses:</dt>
+<dd><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/RecoveredReplicationSourceWALReader.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">RecoveredReplicationSourceWALReader</a></dd>
+</dl>
+<hr>
+<br>
+<pre><a
href="../../../../../../org/apache/hadoop/hbase/classification/InterfaceAudience.Private.html"
title="annotation in
org.apache.hadoop.hbase.classification">@InterfaceAudience.Private</a>
+ <a
href="../../../../../../org/apache/hadoop/hbase/classification/InterfaceStability.Evolving.html"
title="annotation in
org.apache.hadoop.hbase.classification">@InterfaceStability.Evolving</a>
+public class <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.61">ReplicationSourceWALReader</a>
+extends <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true";
title="class or interface in java.lang">Thread</a></pre>
+<div class="block">Reads and filters WAL entries, groups the filtered entries
into batches, and puts the batches onto a queue</div>
+</li>
+</ul>
+</div>
+<div class="summary">
+<ul class="blockList">
+<li class="blockList">
+<!-- ======== NESTED CLASS SUMMARY ======== -->
+<ul class="blockList">
+<li class="blockList"><a name="nested.class.summary">
+<!-- -->
+</a>
+<h3>Nested Class Summary</h3>
+<table class="memberSummary" border="0" cellpadding="3" cellspacing="0"
summary="Nested Class Summary table, listing nested classes, and an
explanation">
+<caption><span>Nested Classes</span><span
class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Class and Description</th>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><code>(package private) static class </code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.WALEntryBatch.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader.WALEntryBatch</a></span></code>
+<div class="block">Holds a batch of WAL entries to replicate, along with some
statistics</div>
+</td>
+</tr>
+</table>
+<ul class="blockList">
+<li class="blockList"><a
name="nested.classes.inherited.from.class.java.lang.Thread">
+<!-- -->
+</a>
+<h3>Nested classes/interfaces inherited from class java.lang.<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true";
title="class or interface in java.lang">Thread</a></h3>
+<code><a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.State.html?is-external=true";
title="class or interface in java.lang">Thread.State</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.UncaughtExceptionHandler.html?is-external=true";
title="class or interface in
java.lang">Thread.UncaughtExceptionHandler</a></code></li>
+</ul>
+</li>
+</ul>
+<!-- =========== FIELD SUMMARY =========== -->
+<ul class="blockList">
+<li class="blockList"><a name="field.summary">
+<!-- -->
+</a>
+<h3>Field Summary</h3>
+<table class="memberSummary" border="0" cellpadding="3" cellspacing="0"
summary="Field Summary table, listing fields, and an explanation">
+<caption><span>Fields</span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Field and Description</th>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><code>private
org.apache.hadoop.conf.Configuration</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#conf">conf</a></span></code> </td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>private long</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#currentPosition">currentPosition</a></span></code> </td>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><code>protected <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/BlockingQueue.html?is-external=true";
title="class or interface in java.util.concurrent">BlockingQueue</a><<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.WALEntryBatch.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader.WALEntryBatch</a>></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#entryBatchQueue">entryBatchQueue</a></span></code> </td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>private boolean</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#eofAutoRecovery">eofAutoRecovery</a></span></code> </td>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><code>private <a
href="../../../../../../org/apache/hadoop/hbase/replication/WALEntryFilter.html"
title="interface in
org.apache.hadoop.hbase.replication">WALEntryFilter</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#filter">filter</a></span></code> </td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>private org.apache.hadoop.fs.FileSystem</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#fs">fs</a></span></code> </td>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><code>private boolean</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#isReaderRunning">isReaderRunning</a></span></code> </td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>private static
org.apache.commons.logging.Log</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#LOG">LOG</a></span></code> </td>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><code>private <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/PriorityBlockingQueue.html?is-external=true";
title="class or interface in
java.util.concurrent">PriorityBlockingQueue</a><org.apache.hadoop.fs.Path></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#logQueue">logQueue</a></span></code> </td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>private int</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#maxRetriesMultiplier">maxRetriesMultiplier</a></span></code> </td>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><code>protected int</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#replicationBatchCountCapacity">replicationBatchCountCapacity</a></span></code> </td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>private long</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#replicationBatchSizeCapacity">replicationBatchSizeCapacity</a></span></code> </td>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><code>private long</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#sleepForRetries">sleepForRetries</a></span></code> </td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>private <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSource</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#source">source</a></span></code> </td>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><code>private long</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#totalBufferQuota">totalBufferQuota</a></span></code> </td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>private <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true";
title="class or interface in
java.util.concurrent.atomic">AtomicLong</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#totalBufferUsed">totalBufferUsed</a></span></code> </td>
+</tr>
+</table>
+<ul class="blockList">
+<li class="blockList"><a name="fields.inherited.from.class.java.lang.Thread">
+<!-- -->
+</a>
+<h3>Fields inherited from class java.lang.<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true";
title="class or interface in java.lang">Thread</a></h3>
+<code><a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#MAX_PRIORITY";
title="class or interface in java.lang">MAX_PRIORITY</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#MIN_PRIORITY";
title="class or interface in java.lang">MIN_PRIORITY</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#NORM_PRIORITY";
title="class or interface in java.lang">NORM_PRIORITY</a></code></li>
+</ul>
+</li>
+</ul>
+<!-- ======== CONSTRUCTOR SUMMARY ======== -->
+<ul class="blockList">
+<li class="blockList"><a name="constructor.summary">
+<!-- -->
+</a>
+<h3>Constructor Summary</h3>
+<table class="memberSummary" border="0" cellpadding="3" cellspacing="0"
summary="Constructor Summary table, listing constructors, and an explanation">
+<caption><span>Constructors</span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colOne" scope="col">Constructor and Description</th>
+</tr>
+<tr class="altColor">
+<td class="colOne"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#ReplicationSourceWALReader-org.apache.hadoop.fs.FileSystem-org.apache.hadoop.conf.Configuration-java.util.concurrent.PriorityBlockingQueue-long-org.apache.hadoop.hbase.replication.WALEntryFilter-org.apache.hadoop.hbase.replication.regionserver.ReplicationSource-">ReplicationSourceWALReader</a></span>(org.apache.hadoop.fs.FileSystem fs,
+ org.apache.hadoop.conf.Configuration conf,
+ <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/PriorityBlockingQueue.html?is-external=true";
title="class or interface in
java.util.concurrent">PriorityBlockingQueue</a><org.apache.hadoop.fs.Path> logQueue,
+ long startPosition,
+ <a
href="../../../../../../org/apache/hadoop/hbase/replication/WALEntryFilter.html"
title="interface in
org.apache.hadoop.hbase.replication">WALEntryFilter</a> filter,
+ <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSource</a> source)</code>
+<div class="block">Creates a reader worker for a given WAL queue.</div>
+</td>
+</tr>
+</table>
+</li>
+</ul>
+<!-- ========== METHOD SUMMARY =========== -->
+<ul class="blockList">
+<li class="blockList"><a name="method.summary">
+<!-- -->
+</a>
+<h3>Method Summary</h3>
+<table class="memberSummary" border="0" cellpadding="3" cellspacing="0"
summary="Method Summary table, listing methods, and an explanation">
+<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span
class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a
href="javascript:show(2);">Instance Methods</a></span><span
class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a
href="javascript:show(8);">Concrete Methods</a></span><span
class="tabEnd"> </span></span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Method and Description</th>
+</tr>
+<tr id="i0" class="altColor">
+<td class="colFirst"><code>private boolean</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#acquireBufferQuota-long-">acquireBufferQuota</a></span>(long size)</code> </td>
+</tr>
+<tr id="i1" class="rowColor">
+<td class="colFirst"><code>private int</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#calculateTotalSizeOfStoreFiles-org.apache.hadoop.hbase.regionserver.wal.WALEdit-">calculateTotalSizeOfStoreFiles</a></span>(<a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALEdit.html"
title="class in
org.apache.hadoop.hbase.regionserver.wal">WALEdit</a> edit)</code>
+<div class="block">Calculate the total size of all the store files</div>
+</td>
+</tr>
+<tr id="i2" class="altColor">
+<td class="colFirst"><code>private boolean</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#checkQuota--">checkQuota</a></span>()</code> </td>
+</tr>
+<tr id="i3" class="rowColor">
+<td class="colFirst"><code>private <a
href="../../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in
org.apache.hadoop.hbase.util">Pair</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true";
title="class or interface in java.lang">Integer</a>,<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true";
title="class or interface in java.lang">Integer</a>></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#countDistinctRowKeysAndHFiles-org.apache.hadoop.hbase.regionserver.wal.WALEdit-">countDistinctRowKeysAndHFiles</a></span>(<a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALEdit.html"
title="class in
org.apache.hadoop.hbase.regionserver.wal">WALEdit</a> edit)</code>
+<div class="block">Count the number of different row keys in the given edit
because of mini-batching.</div>
+</td>
+</tr>
+<tr id="i4" class="altColor">
+<td class="colFirst"><code>private <a
href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html"
title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#filterEntry-org.apache.hadoop.hbase.wal.WAL.Entry-">filterEntry</a></span>(<a
href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html"
title="class in
org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</code> </td>
+</tr>
+<tr id="i5" class="rowColor">
+<td class="colFirst"><code>org.apache.hadoop.fs.Path</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#getCurrentPath--">getCurrentPath</a></span>()</code> </td>
+</tr>
+<tr id="i6" class="altColor">
+<td class="colFirst"><code>private long</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#getEntrySize-org.apache.hadoop.hbase.wal.WAL.Entry-">getEntrySize</a></span>(<a
href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html"
title="class in
org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</code> </td>
+</tr>
+<tr id="i7" class="rowColor">
+<td class="colFirst"><code>protected void</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#handleEmptyWALEntryBatch-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader.WALEntryBatch-org.apache.hadoop.fs.Path-">handleEmptyWALEntryBatch</a></span>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.WALEntryBatch.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader.WALEntryBatch</a> batch,
+
org.apache.hadoop.fs.Path currentPath)</code> </td>
+</tr>
+<tr id="i8" class="altColor">
+<td class="colFirst"><code>private void</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#handleEofException-java.lang.Exception-">handleEofException</a></span>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true";
title="class or interface in java.lang">Exception</a> e)</code> </td>
+</tr>
+<tr id="i9" class="rowColor">
+<td class="colFirst"><code>boolean</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#isReaderRunning--">isReaderRunning</a></span>()</code> </td>
+</tr>
+<tr id="i10" class="altColor">
+<td class="colFirst"><code>private <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.WALEntryBatch.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader.WALEntryBatch</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#readWALEntries-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-">readWALEntries</a></span>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream)</code> </td>
+</tr>
+<tr id="i11" class="rowColor">
+<td class="colFirst"><code>void</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#run--">run</a></span>()</code> </td>
+</tr>
+<tr id="i12" class="altColor">
+<td class="colFirst"><code>void</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#setReaderRunning-boolean-">setReaderRunning</a></span>(boolean readerRunning)</code> </td>
+</tr>
+<tr id="i13" class="rowColor">
+<td class="colFirst"><code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.WALEntryBatch.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader.WALEntryBatch</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#take--">take</a></span>()</code>
+<div class="block">Retrieves the next batch of WAL entries from the queue,
waiting up to the specified time for a
+ batch to become available</div>
+</td>
+</tr>
+<tr id="i14" class="altColor">
+<td class="colFirst"><code>private void</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#updateBatchStats-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader.WALEntryBatch-org.apache.hadoop.hbase.wal.WAL.Entry-long-long-">updateBatchStats</a></span>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.WALEntryBatch.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader.WALEntryBatch</a> batch,
+ <a
href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html"
title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry,
+ long entryPosition,
+ long entrySize)</code> </td>
+</tr>
+<tr id="i15" class="rowColor">
+<td class="colFirst"><code>private boolean</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#updateSerialReplPos-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader.WALEntryBatch-org.apache.hadoop.hbase.wal.WAL.Entry-">updateSerialReplPos</a></span>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.WALEntryBatch.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader.WALEntryBatch</a> batch,
+ <a
href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html"
title="class in
org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</code> </td>
+</tr>
+</table>
+<ul class="blockList">
+<li class="blockList"><a name="methods.inherited.from.class.java.lang.Thread">
+<!-- -->
+</a>
+<h3>Methods inherited from class java.lang.<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true";
title="class or interface in java.lang">Thread</a></h3>
+<code><a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#activeCount--";
title="class or interface in java.lang">activeCount</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#checkAccess--";
title="class or interface in java.lang">checkAccess</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#clone--";
title="class or interface in java.lang">clone</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#countStackFrames--";
title="class or interface in java.lang">countStackFrames</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#currentThread--";
title="class or interface in java.lang">currentThread</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#destroy--";
title="class or interface in java.lang">destroy</a>, <a
href="http://docs.oracle.com
/javase/8/docs/api/java/lang/Thread.html?is-external=true#dumpStack--"
title="class or interface in java.lang">dumpStack</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#enumerate-java.lang.Thread:A-";
title="class or interface in java.lang">enumerate</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#getAllStackTraces--";
title="class or interface in java.lang">getAllStackTraces</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#getContextClassLoader--";
title="class or interface in java.lang">getContextClassLoader</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#getDefaultUncaughtExceptionHandler--";
title="class or interface in
java.lang">getDefaultUncaughtExceptionHandler</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#getId--";
title="class or interface in java.lan
g">getId</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#getName--";
title="class or interface in java.lang">getName</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#getPriority--";
title="class or interface in java.lang">getPriority</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#getStackTrace--";
title="class or interface in java.lang">getStackTrace</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#getState--";
title="class or interface in java.lang">getState</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#getThreadGroup--";
title="class or interface in java.lang">getThreadGroup</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#getUncaughtExceptionHandler--";
title="class or interface in java.lang">getUncaughtExceptionHa
ndler</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#holdsLock-java.lang.Object-";
title="class or interface in java.lang">holdsLock</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#interrupt--";
title="class or interface in java.lang">interrupt</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#interrupted--";
title="class or interface in java.lang">interrupted</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#isAlive--";
title="class or interface in java.lang">isAlive</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#isDaemon--";
title="class or interface in java.lang">isDaemon</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#isInterrupted--";
title="class or interface in java.lang">isInterrupted</a>, <a
href="http://docs.o
racle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#join--"
title="class or interface in java.lang">join</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#join-long-";
title="class or interface in java.lang">join</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#join-long-int-";
title="class or interface in java.lang">join</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#resume--";
title="class or interface in java.lang">resume</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#setContextClassLoader-java.lang.ClassLoader-";
title="class or interface in java.lang">setContextClassLoader</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#setDaemon-boolean-";
title="class or interface in java.lang">setDaemon</a>, <a
href="http://docs.oracle.com/javase/8/docs/api
/java/lang/Thread.html?is-external=true#setDefaultUncaughtExceptionHandler-java.lang.Thread.UncaughtExceptionHandler-"
title="class or interface in
java.lang">setDefaultUncaughtExceptionHandler</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#setName-java.lang.String-";
title="class or interface in java.lang">setName</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#setPriority-int-";
title="class or interface in java.lang">setPriority</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#setUncaughtExceptionHandler-java.lang.Thread.UncaughtExceptionHandler-";
title="class or interface in java.lang">setUncaughtExceptionHandler</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#sleep-long-";
title="class or interface in java.lang">sleep</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-ext
ernal=true#sleep-long-int-" title="class or interface in java.lang">sleep</a>,
<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#start--";
title="class or interface in java.lang">start</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#stop--";
title="class or interface in java.lang">stop</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#stop-java.lang.Throwable-";
title="class or interface in java.lang">stop</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#suspend--";
title="class or interface in java.lang">suspend</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#toString--";
title="class or interface in java.lang">toString</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#yield--";
title="class or interface in java.lang">yield</a><
/code></li>
+</ul>
+<ul class="blockList">
+<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object">
+<!-- -->
+</a>
+<h3>Methods inherited from class java.lang.<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
title="class or interface in java.lang">Object</a></h3>
+<code><a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#equals-java.lang.Object-";
title="class or interface in java.lang">equals</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#finalize--";
title="class or interface in java.lang">finalize</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#getClass--";
title="class or interface in java.lang">getClass</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#hashCode--";
title="class or interface in java.lang">hashCode</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#notify--";
title="class or interface in java.lang">notify</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#notifyAll--";
title="class or interface in java.lang">notifyAll</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/j
ava/lang/Object.html?is-external=true#wait--" title="class or interface in
java.lang">wait</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-";
title="class or interface in java.lang">wait</a>, <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-int-";
title="class or interface in java.lang">wait</a></code></li>
+</ul>
+</li>
+</ul>
+</li>
+</ul>
+</div>
+<div class="details">
+<ul class="blockList">
+<li class="blockList">
+<!-- ============ FIELD DETAIL =========== -->
+<ul class="blockList">
+<li class="blockList"><a name="field.detail">
+<!-- -->
+</a>
+<h3>Field Detail</h3>
+<a name="LOG">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>LOG</h4>
+<pre>private static final org.apache.commons.logging.Log <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.62">LOG</a></pre>
+</li>
+</ul>
+<a name="logQueue">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>logQueue</h4>
+<pre>private final <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/PriorityBlockingQueue.html?is-external=true";
title="class or interface in
java.util.concurrent">PriorityBlockingQueue</a><org.apache.hadoop.fs.Path>
<a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.64">logQueue</a></pre>
+</li>
+</ul>
+<a name="fs">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>fs</h4>
+<pre>private final org.apache.hadoop.fs.FileSystem <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.65">fs</a></pre>
+</li>
+</ul>
+<a name="conf">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>conf</h4>
+<pre>private final org.apache.hadoop.conf.Configuration <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.66">conf</a></pre>
+</li>
+</ul>
+<a name="filter">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>filter</h4>
+<pre>private final <a
href="../../../../../../org/apache/hadoop/hbase/replication/WALEntryFilter.html"
title="interface in org.apache.hadoop.hbase.replication">WALEntryFilter</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.67">filter</a></pre>
+</li>
+</ul>
+<a name="source">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>source</h4>
+<pre>private final <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSource</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.68">source</a></pre>
+</li>
+</ul>
+<a name="entryBatchQueue">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>entryBatchQueue</h4>
+<pre>protected final <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/BlockingQueue.html?is-external=true";
title="class or interface in java.util.concurrent">BlockingQueue</a><<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.WALEntryBatch.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader.WALEntryBatch</a>>
<a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.70">entryBatchQueue</a></pre>
+</li>
+</ul>
+<a name="replicationBatchSizeCapacity">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>replicationBatchSizeCapacity</h4>
+<pre>private final long <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.72">replicationBatchSizeCapacity</a></pre>
+</li>
+</ul>
+<a name="replicationBatchCountCapacity">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>replicationBatchCountCapacity</h4>
+<pre>protected final int <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.74">replicationBatchCountCapacity</a></pre>
+</li>
+</ul>
+<a name="currentPosition">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>currentPosition</h4>
+<pre>private long <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.76">currentPosition</a></pre>
+</li>
+</ul>
+<a name="sleepForRetries">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>sleepForRetries</h4>
+<pre>private final long <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.77">sleepForRetries</a></pre>
+</li>
+</ul>
+<a name="maxRetriesMultiplier">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>maxRetriesMultiplier</h4>
+<pre>private final int <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.78">maxRetriesMultiplier</a></pre>
+</li>
+</ul>
+<a name="eofAutoRecovery">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>eofAutoRecovery</h4>
+<pre>private final boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.79">eofAutoRecovery</a></pre>
+</li>
+</ul>
+<a name="isReaderRunning">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>isReaderRunning</h4>
+<pre>private boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.82">isReaderRunning</a></pre>
+</li>
+</ul>
+<a name="totalBufferUsed">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>totalBufferUsed</h4>
+<pre>private <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true";
title="class or interface in java.util.concurrent.atomic">AtomicLong</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.84">totalBufferUsed</a></pre>
+</li>
+</ul>
+<a name="totalBufferQuota">
+<!-- -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>totalBufferQuota</h4>
+<pre>private long <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.85">totalBufferQuota</a></pre>
+</li>
+</ul>
+</li>
+</ul>
+<!-- ========= CONSTRUCTOR DETAIL ======== -->
+<ul class="blockList">
+<li class="blockList"><a name="constructor.detail">
+<!-- -->
+</a>
+<h3>Constructor Detail</h3>
+<a
name="ReplicationSourceWALReader-org.apache.hadoop.fs.FileSystem-org.apache.hadoop.conf.Configuration-java.util.concurrent.PriorityBlockingQueue-long-org.apache.hadoop.hbase.replication.WALEntryFilter-org.apache.hadoop.hbase.replication.regionserver.ReplicationSource-">
+<!-- -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>ReplicationSourceWALReader</h4>
+<pre>public <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.97">ReplicationSourceWALReader</a>(org.apache.hadoop.fs.FileSystem fs,
+
org.apache.hadoop.conf.Configuration conf,
+ <a
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/PriorityBlockingQueue.html?is-external=true";
title="class or interface in
java.util.concurrent">PriorityBlockingQueue</a><org.apache.hadoop.fs.Path> logQueue,
+ long startPosition,
+ <a
href="../../../../../../org/apache/hadoop/hbase/replication/WALEntryFilter.html"
title="interface in
org.apache.hadoop.hbase.replication">WALEntryFilter</a> filter,
+ <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSource</a> source)</pre>
+<div class="block">Creates a reader worker for a given WAL queue. Reads WAL
entries off a given queue, batches the
+ entries, and puts them on a batch queue.</div>
+<dl>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>fs</code> - the files system to use</dd>
+<dd><code>conf</code> - configuration to use</dd>
+<dd><code>logQueue</code> - The WAL queue to read off of</dd>
+<dd><code>startPosition</code> - position in the first WAL to start reading
from</dd>
+<dd><code>filter</code> - The filter to use while reading</dd>
+<dd><code>source</code> - replication source</dd>
+</dl>
+</li>
+</ul>
+</li>
+</ul>
+<!-- ============ METHOD DETAIL ========== -->
+<ul class="blockList">
+<li class="blockList"><a name="method.detail">
+<!-- -->
+</a>
+<h3>Method Detail</h3>
+<a name="run--">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>run</h4>
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.129">run</a>()</pre>
+<dl>
+<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
+<dd><code><a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true#run--";
title="class or interface in java.lang">run</a></code> in
interface <code><a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true";
title="class or interface in java.lang">Runnable</a></code></dd>
+<dt><span class="overrideSpecifyLabel">Overrides:</span></dt>
+<dd><code><a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true#run--";
title="class or interface in java.lang">run</a></code> in
class <code><a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true";
title="class or interface in java.lang">Thread</a></code></dd>
+</dl>
+</li>
+</ul>
+<a
name="readWALEntries-org.apache.hadoop.hbase.replication.regionserver.WALEntryStream-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>readWALEntries</h4>
+<pre>private <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.WALEntryBatch.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader.WALEntryBatch</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.168">readWALEntries</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">WALEntryStream</a> entryStream)
+ throws <a
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
title="class or interface in java.io">IOException</a></pre>
+<dl>
+<dt><span class="throwsLabel">Throws:</span></dt>
+<dd><code><a
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
title="class or interface in java.io">IOException</a></code></dd>
+</dl>
+</li>
+</ul>
+<a
name="handleEmptyWALEntryBatch-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader.WALEntryBatch-org.apache.hadoop.fs.Path-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>handleEmptyWALEntryBatch</h4>
+<pre>protected void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.198">handleEmptyWALEntryBatch</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.WALEntryBatch.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader.WALEntryBatch</a> batch,
+
org.apache.hadoop.fs.Path currentPath)
+ throws <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true";
title="class or interface in java.lang">InterruptedException</a></pre>
+<dl>
+<dt><span class="throwsLabel">Throws:</span></dt>
+<dd><code><a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true";
title="class or interface in java.lang">InterruptedException</a></code></dd>
+</dl>
+</li>
+</ul>
+<a name="handleEofException-java.lang.Exception-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>handleEofException</h4>
+<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.207">handleEofException</a>(<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true";
title="class or interface in java.lang">Exception</a> e)</pre>
+</li>
+</ul>
+<a name="getCurrentPath--">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>getCurrentPath</h4>
+<pre>public org.apache.hadoop.fs.Path <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.221">getCurrentPath</a>()</pre>
+</li>
+</ul>
+<a name="checkQuota--">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>checkQuota</h4>
+<pre>private boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.232">checkQuota</a>()</pre>
+</li>
+</ul>
+<a name="filterEntry-org.apache.hadoop.hbase.wal.WAL.Entry-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>filterEntry</h4>
+<pre>private <a
href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html"
title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.241">filterEntry</a>(<a
href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html"
title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</pre>
+</li>
+</ul>
+<a
name="updateSerialReplPos-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader.WALEntryBatch-org.apache.hadoop.hbase.wal.WAL.Entry-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>updateSerialReplPos</h4>
+<pre>private boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.252">updateSerialReplPos</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.WALEntryBatch.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader.WALEntryBatch</a> batch,
+ <a
href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html"
title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)
+ throws <a
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
title="class or interface in java.io">IOException</a></pre>
+<dl>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>true if we should stop reading because we're at REGION_CLOSE</dd>
+<dt><span class="throwsLabel">Throws:</span></dt>
+<dd><code><a
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
title="class or interface in java.io">IOException</a></code></dd>
+</dl>
+</li>
+</ul>
+<a name="take--">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>take</h4>
+<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.WALEntryBatch.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader.WALEntryBatch</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.282">take</a>()
+ throws <a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true";
title="class or interface in java.lang">InterruptedException</a></pre>
+<div class="block">Retrieves the next batch of WAL entries from the queue,
waiting up to the specified time for a
+ batch to become available</div>
+<dl>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>A batch of entries, along with the position in the log after reading the
batch</dd>
+<dt><span class="throwsLabel">Throws:</span></dt>
+<dd><code><a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true";
title="class or interface in java.lang">InterruptedException</a></code> - if
interrupted while waiting</dd>
+</dl>
+</li>
+</ul>
+<a name="getEntrySize-org.apache.hadoop.hbase.wal.WAL.Entry-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>getEntrySize</h4>
+<pre>private long <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.286">getEntrySize</a>(<a
href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html"
title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry)</pre>
+</li>
+</ul>
+<a
name="updateBatchStats-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader.WALEntryBatch-org.apache.hadoop.hbase.wal.WAL.Entry-long-long-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>updateBatchStats</h4>
+<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.291">updateBatchStats</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.WALEntryBatch.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceWALReader.WALEntryBatch</a> batch,
+ <a
href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html"
title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a> entry,
+ long entryPosition,
+ long entrySize)</pre>
+</li>
+</ul>
+<a
name="countDistinctRowKeysAndHFiles-org.apache.hadoop.hbase.regionserver.wal.WALEdit-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>countDistinctRowKeysAndHFiles</h4>
+<pre>private <a
href="../../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in
org.apache.hadoop.hbase.util">Pair</a><<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true";
title="class or interface in java.lang">Integer</a>,<a
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true";
title="class or interface in java.lang">Integer</a>> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.308">countDistinctRowKeysAndHFiles</a>(<a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALEdit.html"
title="class in
org.apache.hadoop.hbase.regionserver.wal">WALEdit</a> edit)</pre>
+<div class="block">Count the number of different row keys in the given edit
because of mini-batching. We assume
+ that there's at least one Cell in the WALEdit.</div>
+<dl>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>edit</code> - edit to count row keys from</dd>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>number of different row keys and HFiles</dd>
+</dl>
+</li>
+</ul>
+<a
name="calculateTotalSizeOfStoreFiles-org.apache.hadoop.hbase.regionserver.wal.WALEdit-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>calculateTotalSizeOfStoreFiles</h4>
+<pre>private int <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.346">calculateTotalSizeOfStoreFiles</a>(<a
href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/WALEdit.html"
title="class in
org.apache.hadoop.hbase.regionserver.wal">WALEdit</a> edit)</pre>
+<div class="block">Calculate the total size of all the store files</div>
+<dl>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>edit</code> - edit to count row keys from</dd>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>the total size of the store files</dd>
+</dl>
+</li>
+</ul>
+<a name="acquireBufferQuota-long-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>acquireBufferQuota</h4>
+<pre>private boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.375">acquireBufferQuota</a>(long size)</pre>
+<dl>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>size</code> - delta size for grown buffer</dd>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>true if we should clear buffer and push all</dd>
+</dl>
+</li>
+</ul>
+<a name="isReaderRunning--">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>isReaderRunning</h4>
+<pre>public boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.382">isReaderRunning</a>()</pre>
+<dl>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>whether the reader thread is running</dd>
+</dl>
+</li>
+</ul>
+<a name="setReaderRunning-boolean-">
+<!-- -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>setReaderRunning</h4>
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html#line.389">setReaderRunning</a>(boolean readerRunning)</pre>
+<dl>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>readerRunning</code> - the readerRunning to set</dd>
+</dl>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+</ul>
+</div>
+</div>
+<!-- ========= END OF CLASS DATA ========= -->
+<!-- ======= START OF BOTTOM NAVBAR ====== -->
+<div class="bottomNav"><a name="navbar.bottom">
+<!-- -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation
links">Skip navigation links</a></div>
+<a name="navbar.bottom.firstrow">
+<!-- -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../../../../overview-summary.html">Overview</a></li>
+<li><a href="package-summary.html">Package</a></li>
+<li class="navBarCell1Rev">Class</li>
+<li><a href="class-use/ReplicationSourceWALReader.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">Help</a></li>
+</ul>
+</div>
+<div class="subNav">
+<ul class="navList">
+<li><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html"
title="enum in org.apache.hadoop.hbase.replication.regionserver"><span
class="typeNameLink">Prev Class</span></a></li>
+<li><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.WALEntryBatch.html"
title="class in org.apache.hadoop.hbase.replication.regionserver"><span
class="typeNameLink">Next Class</span></a></li>
+</ul>
+<ul class="navList">
+<li><a
href="../../../../../../index.html?org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html"
target="_top">Frames</a></li>
+<li><a href="ReplicationSourceWALReader.html"
target="_top">No Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_bottom">
+<li><a
href="../../../../../../allclasses-noframe.html">All Classes</a></li>
+</ul>
+<div>
+<script type="text/javascript"><!--
+ allClassesLink = document.getElementById("allclasses_navbar_bottom");
+ if(window==top) {
+ allClassesLink.style.display = "block";
+ }
+ else {
+ allClassesLink.style.display = "none";
+ }
+ //-->
+</script>
+</div>
+<div>
+<ul class="subNavList">
+<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="subNavList">
+<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>
+<a name="skip.navbar.bottom">
+<!-- -->
+</a></div>
+<!-- ======== END OF BOTTOM NAVBAR ======= -->
+<p class="legalCopy"><small>Copyright © 2007–2017 <a
href="https://www.apache.org/";>The Apache Software Foundation</a>. All rights
reserved.</small></p>
+</body>
+</html>
