http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b618ac40/devapidocs/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html b/devapidocs/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html deleted file mode 100644 index 980f8bd..0000000 --- a/devapidocs/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html +++ /dev/null @@ -1,1070 +0,0 @@ -<!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>TableBasedReplicationQueuesImpl (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="TableBasedReplicationQueuesImpl (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,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":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/TableBasedReplicationQueuesImpl.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/TableBasedReplicationQueuesClientImpl.html" title="class in org.apache.hadoop.hbase.replication"><span class="typeNameLink">Prev Class</span></a></li> -<li><a href="../../../../../org/apache/hadoop/hbase/replication/WALCellFilter.html" title="interface in org.apache.hadoop.hbase.replication"><span class="typeNameLink">Next Class</span></a></li> -</ul> -<ul class="navList"> -<li><a href="../../../../../index.html?org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html" target="_top">Frames</a></li> -<li><a href="TableBasedReplicationQueuesImpl.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>Nested | </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</div> -<h2 title="Class TableBasedReplicationQueuesImpl" class="title">Class TableBasedReplicationQueuesImpl</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="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html" title="class in org.apache.hadoop.hbase.replication">org.apache.hadoop.hbase.replication.ReplicationTableBase</a></li> -<li> -<ul class="inheritance"> -<li>org.apache.hadoop.hbase.replication.TableBasedReplicationQueuesImpl</li> -</ul> -</li> -</ul> -</li> -</ul> -<div class="description"> -<ul class="blockList"> -<li class="blockList"> -<dl> -<dt>All Implemented Interfaces:</dt> -<dd><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></dd> -</dl> -<hr> -<br> -<pre>@InterfaceAudience.Private -public class <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.59">TableBasedReplicationQueuesImpl</a> -extends <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html" title="class in org.apache.hadoop.hbase.replication">ReplicationTableBase</a> -implements <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></pre> -<div class="block">This class provides an implementation of the ReplicationQueues interface using an HBase table - "Replication Table". It utilizes the ReplicationTableBase to access the Replication Table.</div> -</li> -</ul> -</div> -<div class="summary"> -<ul class="blockList"> -<li class="blockList"> -<!-- =========== 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 static byte[]</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#EMPTY_STRING_BYTES">EMPTY_STRING_BYTES</a></span></code> </td> -</tr> -<tr class="rowColor"> -<td class="colFirst"><code>private static byte[]</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#INITIAL_OFFSET_BYTES">INITIAL_OFFSET_BYTES</a></span></code> </td> -</tr> -<tr class="altColor"> -<td class="colFirst"><code>private static org.slf4j.Logger</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#LOG">LOG</a></span></code> </td> -</tr> -<tr class="rowColor"> -<td class="colFirst"><code>private <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html" title="class in org.apache.hadoop.hbase.replication">ReplicationStateZKBase</a></code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#replicationState">replicationState</a></span></code> </td> -</tr> -<tr class="altColor"> -<td class="colFirst"><code>private <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#serverName">serverName</a></span></code> </td> -</tr> -<tr class="rowColor"> -<td class="colFirst"><code>private byte[]</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#serverNameBytes">serverNameBytes</a></span></code> </td> -</tr> -</table> -<ul class="blockList"> -<li class="blockList"><a name="fields.inherited.from.class.org.apache.hadoop.hbase.replication.ReplicationTableBase"> -<!-- --> -</a> -<h3>Fields inherited from class org.apache.hadoop.hbase.replication.<a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html" title="class in org.apache.hadoop.hbase.replication">ReplicationTableBase</a></h3> -<code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#abortable">abortable</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#CF_QUEUE">CF_QUEUE</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#COL_QUEUE_OWNER">COL_QUEUE_OWNER</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#COL_QUEUE_OWNER_HISTORY">COL_QUEUE_OWNER_HISTORY</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#conf">conf</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#QUEUE_HISTORY_DELIMITER">QUEUE_HISTORY_DELIMITER</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#REPLICATION_TABLE_NAME">REPLICATION_TABLE_NAME</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#ROW_KEY_DELIMITER">ROW_KEY_DELIMITER</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/TableBasedReplicationQueuesImpl.html#TableBasedReplicationQueuesImpl-org.apache.hadoop.conf.Configuration-org.apache.hadoop.hbase.Abortable-org.apache.hadoop.hbase.zookeeper.ZKWatcher-">TableBasedReplicationQueuesImpl</a></span>(org.apache.hadoop.conf.Configuration conf, - <a href="../../../../../org/apache/hadoop/hbase/Abortable.html" title="interface in org.apache.hadoop.hbase">Abortable</a> abort, - <a href="../../../../../org/apache/hadoop/hbase/zookeeper/ZKWatcher.html" title="class in org.apache.hadoop.hbase.zookeeper">ZKWatcher</a> zkw)</code> </td> -</tr> -<tr class="rowColor"> -<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#TableBasedReplicationQueuesImpl-org.apache.hadoop.hbase.replication.ReplicationQueuesArguments-">TableBasedReplicationQueuesImpl</a></span>(<a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesArguments.html" title="class in org.apache.hadoop.hbase.replication">ReplicationQueuesArguments</a> args)</code> </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>void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#addHFileRefs-java.lang.String-java.util.List-">addHFileRefs</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> peerId, - <a href="http://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/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> pairs)</code> -<div class="block">Add new hfile references to the queue.</div> -</td> -</tr> -<tr id="i1" class="rowColor"> -<td class="colFirst"><code>void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#addLog-java.lang.String-java.lang.String-">addLog</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId, - <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> filename)</code> -<div class="block">Add a new WAL file to the given queue.</div> -</td> -</tr> -<tr id="i2" class="altColor"> -<td class="colFirst"><code>void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#addPeerToHFileRefs-java.lang.String-">addPeerToHFileRefs</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> peerId)</code> -<div class="block">Add a peer to hfile reference queue if peer does not exist.</div> -</td> -</tr> -<tr id="i3" class="rowColor"> -<td class="colFirst"><code>private boolean</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#attemptToClaimQueue-org.apache.hadoop.hbase.client.Result-java.lang.String-">attemptToClaimQueue</a></span>(<a href="../../../../../org/apache/hadoop/hbase/client/Result.html" title="class in org.apache.hadoop.hbase.client">Result</a> queue, - <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> originalServer)</code> -<div class="block">Attempt to claim the given queue with a checkAndPut on the OWNER column.</div> -</td> -</tr> -<tr id="i4" class="altColor"> -<td class="colFirst"><code>private <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#buildQueueRowKey-java.lang.String-">buildQueueRowKey</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId)</code> </td> -</tr> -<tr id="i5" class="rowColor"> -<td class="colFirst"><code>private boolean</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#checkQueueExists-java.lang.String-">checkQueueExists</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId)</code> -<div class="block">Check if the queue specified by queueId is stored in HBase</div> -</td> -</tr> -<tr id="i6" class="altColor"> -<td class="colFirst"><code><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/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true"; title="class or interface in java.util">SortedSet</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>>></code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#claimQueue-java.lang.String-java.lang.String-">claimQueue</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> regionserver, - <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId)</code> -<div class="block">Take ownership for the queue identified by queueId and belongs to a dead region server.</div> -</td> -</tr> -<tr id="i7" class="rowColor"> -<td class="colFirst"><code><a href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>></code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#getAllQueues--">getAllQueues</a></span>()</code> -<div class="block">Get a list of all queues for this region server.</div> -</td> -</tr> -<tr id="i8" class="altColor"> -<td class="colFirst"><code><a href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>></code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#getListOfReplicators--">getListOfReplicators</a></span>()</code> -<div class="block">Get a list of all region servers that have outstanding replication queues.</div> -</td> -</tr> -<tr id="i9" class="rowColor"> -<td class="colFirst"><code>long</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#getLogPosition-java.lang.String-java.lang.String-">getLogPosition</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId, - <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> filename)</code> -<div class="block">Get the current position for a specific WAL in a given queue.</div> -</td> -</tr> -<tr id="i10" class="altColor"> -<td class="colFirst"><code><a href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>></code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#getLogsInQueue-java.lang.String-">getLogsInQueue</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId)</code> -<div class="block">Get a list of all WALs in the given queue.</div> -</td> -</tr> -<tr id="i11" class="rowColor"> -<td class="colFirst"><code>private <a href="../../../../../org/apache/hadoop/hbase/client/Result.html" title="class in org.apache.hadoop.hbase.client">Result</a></code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#getResultIfOwner-org.apache.hadoop.hbase.client.Get-">getResultIfOwner</a></span>(<a href="../../../../../org/apache/hadoop/hbase/client/Get.html" title="class in org.apache.hadoop.hbase.client">Get</a> get)</code> -<div class="block">Attempts to run a Get on some queue.</div> -</td> -</tr> -<tr id="i12" class="altColor"> -<td class="colFirst"><code><a href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>></code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#getUnClaimedQueueIds-java.lang.String-">getUnClaimedQueueIds</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> regionserver)</code> -<div class="block">Get queueIds from a dead region server, whose queues has not been claimed by other region - servers.</div> -</td> -</tr> -<tr id="i13" class="rowColor"> -<td class="colFirst"><code>void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#init-java.lang.String-">init</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> serverName)</code> -<div class="block">Initialize the region server replication queue interface.</div> -</td> -</tr> -<tr id="i14" class="altColor"> -<td class="colFirst"><code>boolean</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#isThisOurRegionServer-java.lang.String-">isThisOurRegionServer</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> regionserver)</code> -<div class="block">Checks if the provided znode is the same as this region server's</div> -</td> -</tr> -<tr id="i15" class="rowColor"> -<td class="colFirst"><code>private byte[]</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#queueIdToRowKey-java.lang.String-">queueIdToRowKey</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId)</code> -<div class="block">Convenience method that gets the row key of the queue specified by queueId</div> -</td> -</tr> -<tr id="i16" class="altColor"> -<td class="colFirst"><code>void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#removeAllQueues--">removeAllQueues</a></span>()</code> -<div class="block">Remove all replication queues for this region server.</div> -</td> -</tr> -<tr id="i17" class="rowColor"> -<td class="colFirst"><code>void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#removeHFileRefs-java.lang.String-java.util.List-">removeHFileRefs</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> peerId, - <a href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> files)</code> -<div class="block">Remove hfile references from the queue.</div> -</td> -</tr> -<tr id="i18" class="altColor"> -<td class="colFirst"><code>void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#removeLog-java.lang.String-java.lang.String-">removeLog</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId, - <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> filename)</code> -<div class="block">Remove an WAL file from the given queue.</div> -</td> -</tr> -<tr id="i19" class="rowColor"> -<td class="colFirst"><code>void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#removePeerFromHFileRefs-java.lang.String-">removePeerFromHFileRefs</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> peerId)</code> -<div class="block">Remove a peer from hfile reference queue.</div> -</td> -</tr> -<tr id="i20" class="altColor"> -<td class="colFirst"><code>void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#removeQueue-java.lang.String-">removeQueue</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId)</code> -<div class="block">Remove a replication queue.</div> -</td> -</tr> -<tr id="i21" class="rowColor"> -<td class="colFirst"><code>void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#removeReplicatorIfQueueIsEmpty-java.lang.String-">removeReplicatorIfQueueIsEmpty</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> regionserver)</code> -<div class="block">Remove the znode of region server if the queue is empty.</div> -</td> -</tr> -<tr id="i22" class="altColor"> -<td class="colFirst"><code>private void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#safeQueueUpdate-org.apache.hadoop.hbase.client.Delete-">safeQueueUpdate</a></span>(<a href="../../../../../org/apache/hadoop/hbase/client/Delete.html" title="class in org.apache.hadoop.hbase.client">Delete</a> delete)</code> -<div class="block">See safeQueueUpdate(RowMutations mutate)</div> -</td> -</tr> -<tr id="i23" class="rowColor"> -<td class="colFirst"><code>private void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#safeQueueUpdate-org.apache.hadoop.hbase.client.Put-">safeQueueUpdate</a></span>(<a href="../../../../../org/apache/hadoop/hbase/client/Put.html" title="class in org.apache.hadoop.hbase.client">Put</a> put)</code> -<div class="block">See safeQueueUpdate(RowMutations mutate)</div> -</td> -</tr> -<tr id="i24" class="altColor"> -<td class="colFirst"><code>private void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#safeQueueUpdate-org.apache.hadoop.hbase.client.RowMutations-">safeQueueUpdate</a></span>(<a href="../../../../../org/apache/hadoop/hbase/client/RowMutations.html" title="class in org.apache.hadoop.hbase.client">RowMutations</a> mutate)</code> -<div class="block">Attempt to mutate a given queue in the Replication Table with a checkAndPut on the OWNER column - of the queue.</div> -</td> -</tr> -<tr id="i25" class="rowColor"> -<td class="colFirst"><code>void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#setLogPosition-java.lang.String-java.lang.String-long-">setLogPosition</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId, - <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> filename, - long position)</code> -<div class="block">Set the current position for a specific WAL in a given queue.</div> -</td> -</tr> -</table> -<ul class="blockList"> -<li class="blockList"><a name="methods.inherited.from.class.org.apache.hadoop.hbase.replication.ReplicationTableBase"> -<!-- --> -</a> -<h3>Methods inherited from class org.apache.hadoop.hbase.replication.<a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html" title="class in org.apache.hadoop.hbase.replication">ReplicationTableBase</a></h3> -<code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#buildClaimedQueueHistory-java.lang.String-java.lang.String-">buildClaimedQueueHistory</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#buildQueueRowKey-java.lang.String-java.lang.String-">buildQueueRowKey</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#getAllQueues-java.lang.String-">getAllQueues</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#getInitializationStatus--">getInitializationStatus</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#getLogsInQueue-byte:A-">getLogsInQueue</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#getLogsInQueue-java.lang.String-java.lang.String-">getLogsInQueue</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#ge tOrBlockOnReplicationTable--">getOrBlockOnReplicationTable</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#getQueuesBelongingToServer-java.lang.String-">getQueuesBelongingToServer</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#getRawQueueIdFromRowKey-java.lang.String-">getRawQueueIdFromRowKey</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#queueIdToRowKey-java.lang.String-java.lang.String-">queueIdToRowKey</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#readWALsFromResult-org.apache.hadoop.hbase.client.Result-">readWALsFromResult</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#clone--"; title="class or interface in java.lang">clone</a>, <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/java/lang/Object.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/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.slf4j.Logger <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.62">LOG</a></pre> -</li> -</ul> -<a name="INITIAL_OFFSET_BYTES"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>INITIAL_OFFSET_BYTES</h4> -<pre>private static final byte[] <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.65">INITIAL_OFFSET_BYTES</a></pre> -</li> -</ul> -<a name="EMPTY_STRING_BYTES"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>EMPTY_STRING_BYTES</h4> -<pre>private static final byte[] <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.66">EMPTY_STRING_BYTES</a></pre> -</li> -</ul> -<a name="serverName"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>serverName</h4> -<pre>private <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.68">serverName</a></pre> -</li> -</ul> -<a name="serverNameBytes"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>serverNameBytes</h4> -<pre>private byte[] <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.69">serverNameBytes</a></pre> -</li> -</ul> -<a name="replicationState"> -<!-- --> -</a> -<ul class="blockListLast"> -<li class="blockList"> -<h4>replicationState</h4> -<pre>private <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html" title="class in org.apache.hadoop.hbase.replication">ReplicationStateZKBase</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.73">replicationState</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="TableBasedReplicationQueuesImpl-org.apache.hadoop.hbase.replication.ReplicationQueuesArguments-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>TableBasedReplicationQueuesImpl</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.75">TableBasedReplicationQueuesImpl</a>(<a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesArguments.html" title="class in org.apache.hadoop.hbase.replication">ReplicationQueuesArguments</a> args) - 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="TableBasedReplicationQueuesImpl-org.apache.hadoop.conf.Configuration-org.apache.hadoop.hbase.Abortable-org.apache.hadoop.hbase.zookeeper.ZKWatcher-"> -<!-- --> -</a> -<ul class="blockListLast"> -<li class="blockList"> -<h4>TableBasedReplicationQueuesImpl</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.79">TableBasedReplicationQueuesImpl</a>(org.apache.hadoop.conf.Configuration conf, - <a href="../../../../../org/apache/hadoop/hbase/Abortable.html" title="interface in org.apache.hadoop.hbase">Abortable</a> abort, - <a href="../../../../../org/apache/hadoop/hbase/zookeeper/ZKWatcher.html" title="class in org.apache.hadoop.hbase.zookeeper">ZKWatcher</a> zkw) - 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> -</li> -</ul> -<!-- ============ METHOD DETAIL ========== --> -<ul class="blockList"> -<li class="blockList"><a name="method.detail"> -<!-- --> -</a> -<h3>Method Detail</h3> -<a name="init-java.lang.String-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>init</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.86">init</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> serverName) - throws <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#init-java.lang.String-">ReplicationQueues</a></code></span></div> -<div class="block">Initialize the region server replication queue interface.</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#init-java.lang.String-">init</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>serverName</code> - The server name of the region server that owns the replication queues this - interface manages.</dd> -<dt><span class="throwsLabel">Throws:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></code></dd> -</dl> -</li> -</ul> -<a name="getListOfReplicators--"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>getListOfReplicators</h4> -<pre>public <a href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.92">getListOfReplicators</a>()</pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from class: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#getListOfReplicators--">ReplicationTableBase</a></code></span></div> -<div class="block">Get a list of all region servers that have outstanding replication queues. These servers could - be alive, dead or from a previous run of the cluster.</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#getListOfReplicators--">getListOfReplicators</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -<dt><span class="overrideSpecifyLabel">Overrides:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html#getListOfReplicators--">getListOfReplicators</a></code> in class <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationTableBase.html" title="class in org.apache.hadoop.hbase.replication">ReplicationTableBase</a></code></dd> -<dt><span class="returnLabel">Returns:</span></dt> -<dd>a list of server names</dd> -</dl> -</li> -</ul> -<a name="removeQueue-java.lang.String-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>removeQueue</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.97">removeQueue</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId)</pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#removeQueue-java.lang.String-">ReplicationQueues</a></code></span></div> -<div class="block">Remove a replication queue.</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#removeQueue-java.lang.String-">removeQueue</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>queueId</code> - a String that identifies the queue.</dd> -</dl> -</li> -</ul> -<a name="addLog-java.lang.String-java.lang.String-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>addLog</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.114">addLog</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId, - <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> filename) - throws <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#addLog-java.lang.String-java.lang.String-">ReplicationQueues</a></code></span></div> -<div class="block">Add a new WAL file to the given queue. If the queue does not exist it is created.</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#addLog-java.lang.String-java.lang.String-">addLog</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>queueId</code> - a String that identifies the queue.</dd> -<dd><code>filename</code> - name of the WAL</dd> -<dt><span class="throwsLabel">Throws:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></code></dd> -</dl> -</li> -</ul> -<a name="removeLog-java.lang.String-java.lang.String-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>removeLog</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.136">removeLog</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId, - <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> filename)</pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#removeLog-java.lang.String-java.lang.String-">ReplicationQueues</a></code></span></div> -<div class="block">Remove an WAL file from the given queue.</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#removeLog-java.lang.String-java.lang.String-">removeLog</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>queueId</code> - a String that identifies the queue.</dd> -<dd><code>filename</code> - name of the WAL</dd> -</dl> -</li> -</ul> -<a name="setLogPosition-java.lang.String-java.lang.String-long-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>setLogPosition</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.149">setLogPosition</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId, - <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> filename, - long position)</pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#setLogPosition-java.lang.String-java.lang.String-long-">ReplicationQueues</a></code></span></div> -<div class="block">Set the current position for a specific WAL in a given queue.</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#setLogPosition-java.lang.String-java.lang.String-long-">setLogPosition</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>queueId</code> - a String that identifies the queue</dd> -<dd><code>filename</code> - name of the WAL</dd> -<dd><code>position</code> - the current position in the file</dd> -</dl> -</li> -</ul> -<a name="getLogPosition-java.lang.String-java.lang.String-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>getLogPosition</h4> -<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.173">getLogPosition</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId, - <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> filename) - throws <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#getLogPosition-java.lang.String-java.lang.String-">ReplicationQueues</a></code></span></div> -<div class="block">Get the current position for a specific WAL in a given queue.</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#getLogPosition-java.lang.String-java.lang.String-">getLogPosition</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>queueId</code> - a String that identifies the queue</dd> -<dd><code>filename</code> - name of the WAL</dd> -<dt><span class="returnLabel">Returns:</span></dt> -<dd>the current position in the file</dd> -<dt><span class="throwsLabel">Throws:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></code></dd> -</dl> -</li> -</ul> -<a name="removeAllQueues--"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>removeAllQueues</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.191">removeAllQueues</a>()</pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#removeAllQueues--">ReplicationQueues</a></code></span></div> -<div class="block">Remove all replication queues for this region server.</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#removeAllQueues--">removeAllQueues</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -</dl> -</li> -</ul> -<a name="getLogsInQueue-java.lang.String-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>getLogsInQueue</h4> -<pre>public <a href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.199">getLogsInQueue</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId)</pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#getLogsInQueue-java.lang.String-">ReplicationQueues</a></code></span></div> -<div class="block">Get a list of all WALs in the given queue.</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#getLogsInQueue-java.lang.String-">getLogsInQueue</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>queueId</code> - a String that identifies the queue</dd> -<dt><span class="returnLabel">Returns:</span></dt> -<dd>a list of WALs, null if no such queue exists for this server</dd> -</dl> -</li> -</ul> -<a name="getAllQueues--"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>getAllQueues</h4> -<pre>public <a href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.228">getAllQueues</a>()</pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#getAllQueues--">ReplicationQueues</a></code></span></div> -<div class="block">Get a list of all queues for this region server.</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#getAllQueues--">getAllQueues</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -<dt><span class="returnLabel">Returns:</span></dt> -<dd>a list of queueIds, an empty list if this region server is dead and has no outstanding queues</dd> -</dl> -</li> -</ul> -<a name="getUnClaimedQueueIds-java.lang.String-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>getUnClaimedQueueIds</h4> -<pre>public <a href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.232">getUnClaimedQueueIds</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> regionserver)</pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#getUnClaimedQueueIds-java.lang.String-">ReplicationQueues</a></code></span></div> -<div class="block">Get queueIds from a dead region server, whose queues has not been claimed by other region - servers.</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#getUnClaimedQueueIds-java.lang.String-">getUnClaimedQueueIds</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -<dt><span class="returnLabel">Returns:</span></dt> -<dd>empty if the queue exists but no children, null if the queue does not exist.</dd> -</dl> -</li> -</ul> -<a name="removeReplicatorIfQueueIsEmpty-java.lang.String-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>removeReplicatorIfQueueIsEmpty</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.250">removeReplicatorIfQueueIsEmpty</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> regionserver)</pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#removeReplicatorIfQueueIsEmpty-java.lang.String-">ReplicationQueues</a></code></span></div> -<div class="block">Remove the znode of region server if the queue is empty.</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#removeReplicatorIfQueueIsEmpty-java.lang.String-">removeReplicatorIfQueueIsEmpty</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -</dl> -</li> -</ul> -<a name="claimQueue-java.lang.String-java.lang.String-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>claimQueue</h4> -<pre>public <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/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true"; title="class or interface in java.util">SortedSet</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>>> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.255">claimQueue</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> regionserver, - <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId)</pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#claimQueue-java.lang.String-java.lang.String-">ReplicationQueues</a></code></span></div> -<div class="block">Take ownership for the queue identified by queueId and belongs to a dead region server.</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#claimQueue-java.lang.String-java.lang.String-">claimQueue</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>regionserver</code> - the id of the dead region server</dd> -<dd><code>queueId</code> - the id of the queue</dd> -<dt><span class="returnLabel">Returns:</span></dt> -<dd>the new PeerId and A SortedSet of WALs in its queue, and null if no unclaimed queue.</dd> -</dl> -</li> -</ul> -<a name="isThisOurRegionServer-java.lang.String-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>isThisOurRegionServer</h4> -<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.292">isThisOurRegionServer</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> regionserver)</pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#isThisOurRegionServer-java.lang.String-">ReplicationQueues</a></code></span></div> -<div class="block">Checks if the provided znode is the same as this region server's</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#isThisOurRegionServer-java.lang.String-">isThisOurRegionServer</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>regionserver</code> - the id of the region server</dd> -<dt><span class="returnLabel">Returns:</span></dt> -<dd>if this is this rs's znode</dd> -</dl> -</li> -</ul> -<a name="addPeerToHFileRefs-java.lang.String-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>addPeerToHFileRefs</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.297">addPeerToHFileRefs</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> peerId) - throws <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#addPeerToHFileRefs-java.lang.String-">ReplicationQueues</a></code></span></div> -<div class="block">Add a peer to hfile reference queue if peer does not exist.</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#addPeerToHFileRefs-java.lang.String-">addPeerToHFileRefs</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>peerId</code> - peer cluster id to be added</dd> -<dt><span class="throwsLabel">Throws:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></code> - if fails to add a peer id to hfile reference queue</dd> -</dl> -</li> -</ul> -<a name="removePeerFromHFileRefs-java.lang.String-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>removePeerFromHFileRefs</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.303">removePeerFromHFileRefs</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> peerId)</pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#removePeerFromHFileRefs-java.lang.String-">ReplicationQueues</a></code></span></div> -<div class="block">Remove a peer from hfile reference queue.</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#removePeerFromHFileRefs-java.lang.String-">removePeerFromHFileRefs</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>peerId</code> - peer cluster id to be removed</dd> -</dl> -</li> -</ul> -<a name="addHFileRefs-java.lang.String-java.util.List-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>addHFileRefs</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.309">addHFileRefs</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> peerId, - <a href="http://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/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> pairs) - throws <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#addHFileRefs-java.lang.String-java.util.List-">ReplicationQueues</a></code></span></div> -<div class="block">Add new hfile references to the queue.</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#addHFileRefs-java.lang.String-java.util.List-">addHFileRefs</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>peerId</code> - peer cluster id to which the hfiles need to be replicated</dd> -<dd><code>pairs</code> - list of pairs of { HFile location in staging dir, HFile path in region dir which - will be added in the queue }</dd> -<dt><span class="throwsLabel">Throws:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></code> - if fails to add a hfile reference</dd> -</dl> -</li> -</ul> -<a name="removeHFileRefs-java.lang.String-java.util.List-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>removeHFileRefs</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.316">removeHFileRefs</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> peerId, - <a href="http://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="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> files)</pre> -<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#removeHFileRefs-java.lang.String-java.util.List-">ReplicationQueues</a></code></span></div> -<div class="block">Remove hfile references from the queue.</div> -<dl> -<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#removeHFileRefs-java.lang.String-java.util.List-">removeHFileRefs</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueues</a></code></dd> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>peerId</code> - peer cluster id from which this hfile references needs to be removed</dd> -<dd><code>files</code> - list of hfile references to be removed</dd> -</dl> -</li> -</ul> -<a name="buildQueueRowKey-java.lang.String-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>buildQueueRowKey</h4> -<pre>private <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.321">buildQueueRowKey</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId)</pre> -</li> -</ul> -<a name="queueIdToRowKey-java.lang.String-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>queueIdToRowKey</h4> -<pre>private byte[] <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.330">queueIdToRowKey</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId)</pre> -<div class="block">Convenience method that gets the row key of the queue specified by queueId</div> -<dl> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>queueId</code> - queueId of a queue in this server</dd> -<dt><span class="returnLabel">Returns:</span></dt> -<dd>the row key of the queue in the Replication Table</dd> -</dl> -</li> -</ul> -<a name="safeQueueUpdate-org.apache.hadoop.hbase.client.Put-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>safeQueueUpdate</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.339">safeQueueUpdate</a>(<a href="../../../../../org/apache/hadoop/hbase/client/Put.html" title="class in org.apache.hadoop.hbase.client">Put</a> put) - throws <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a>, - <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> -<div class="block">See safeQueueUpdate(RowMutations mutate)</div> -<dl> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>put</code> - Row mutation to perform on the queue</dd> -<dt><span class="throwsLabel">Throws:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></code></dd> -<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="safeQueueUpdate-org.apache.hadoop.hbase.client.Delete-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>safeQueueUpdate</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.350">safeQueueUpdate</a>(<a href="../../../../../org/apache/hadoop/hbase/client/Delete.html" title="class in org.apache.hadoop.hbase.client">Delete</a> delete) - throws <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a>, - <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> -<div class="block">See safeQueueUpdate(RowMutations mutate)</div> -<dl> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>delete</code> - Row mutation to perform on the queue</dd> -<dt><span class="throwsLabel">Throws:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></code></dd> -<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="safeQueueUpdate-org.apache.hadoop.hbase.client.RowMutations-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>safeQueueUpdate</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.364">safeQueueUpdate</a>(<a href="../../../../../org/apache/hadoop/hbase/client/RowMutations.html" title="class in org.apache.hadoop.hbase.client">RowMutations</a> mutate) - throws <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a>, - <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> -<div class="block">Attempt to mutate a given queue in the Replication Table with a checkAndPut on the OWNER column - of the queue. Abort the server if this checkAndPut fails: which means we have somehow lost - ownership of the column or an IO Exception has occurred during the transaction.</div> -<dl> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>mutate</code> - Mutation to perform on a given queue</dd> -<dt><span class="throwsLabel">Throws:</span></dt> -<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></code></dd> -<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="checkQueueExists-java.lang.String-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>checkQueueExists</h4> -<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.382">checkQueueExists</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId) - throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> -<div class="block">Check if the queue specified by queueId is stored in HBase</div> -<dl> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>queueId</code> - Either raw or reclaimed format of the queueId</dd> -<dt><span class="returnLabel">Returns:</span></dt> -<dd>Whether the queue is stored in HBase</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="attemptToClaimQueue-org.apache.hadoop.hbase.client.Result-java.lang.String-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>attemptToClaimQueue</h4> -<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.398">attemptToClaimQueue</a>(<a href="../../../../../org/apache/hadoop/hbase/client/Result.html" title="class in org.apache.hadoop.hbase.client">Result</a> queue, - <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> originalServer) - throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> -<div class="block">Attempt to claim the given queue with a checkAndPut on the OWNER column. We check that the - recently killed server is still the OWNER before we claim it.</div> -<dl> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>queue</code> - The queue that we are trying to claim</dd> -<dd><code>originalServer</code> - The server that originally owned the queue</dd> -<dt><span class="returnLabel">Returns:</span></dt> -<dd>Whether we successfully claimed the queue</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="getResultIfOwner-org.apache.hadoop.hbase.client.Get-"> -<!-- --> -</a> -<ul class="blockListLast"> -<li class="blockList"> -<h4>getResultIfOwner</h4> -<pre>private <a href="../../../../../org/apache/hadoop/hbase/client/Result.html" title="class in org.apache.hadoop.hbase.client">Result</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html#line.426">getResultIfOwner</a>(<a href="../../../../../org/apache/hadoop/hbase/client/Get.html" title="class in org.apache.hadoop.hbase.client">Get</a> get) - throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> -<div class="block">Attempts to run a Get on some queue. Will only return a non-null result if we currently own - the queue.</div> -<dl> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>get</code> - The Get that we want to query</dd> -<dt><span class="returnLabel">Returns:</span></dt> -<dd>The result of the Get if this server is the owner of the queue. Else it returns null.</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> -</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/TableBasedReplicationQueuesImpl.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/TableBasedReplicationQueuesClientImpl.html" title="class in org.apache.hadoop.hbase.replication"><span class="typeNameLink">Prev Class</span></a></li> -<li><a href="../../../../../org/apache/hadoop/hbase/replication/WALCellFilter.html" title="interface in org.apache.hadoop.hbase.replication"><span class="typeNameLink">Next Class</span></a></li> -</ul> -<ul class="navList"> -<li><a href="../../../../../index.html?org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html" target="_top">Frames</a></li> -<li><a href="TableBasedReplicationQueuesImpl.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>Nested | </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>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b618ac40/devapidocs/org/apache/hadoop/hbase/replication/WALCellFilter.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/WALCellFilter.html b/devapidocs/org/apache/hadoop/hbase/replication/WALCellFilter.html index 5b156c5..e552c35 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/WALCellFilter.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/WALCellFilter.html @@ -49,7 +49,7 @@ var activeTableTab = "activeTableTab"; </div> <div class="subNav"> <ul class="navList"> -<li><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html" title="class in org.apache.hadoop.hbase.replication"><span class="typeNameLink">Prev Class</span></a></li> +<li><a href="../../../../../org/apache/hadoop/hbase/replication/SystemTableWALEntryFilter.html" title="class in org.apache.hadoop.hbase.replication"><span class="typeNameLink">Prev Class</span></a></li> <li><a href="../../../../../org/apache/hadoop/hbase/replication/WALEntryFilter.html" title="interface in org.apache.hadoop.hbase.replication"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> @@ -196,7 +196,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic </div> <div class="subNav"> <ul class="navList"> -<li><a href="../../../../../org/apache/hadoop/hbase/replication/TableBasedReplicationQueuesImpl.html" title="class in org.apache.hadoop.hbase.replication"><span class="typeNameLink">Prev Class</span></a></li> +<li><a href="../../../../../org/apache/hadoop/hbase/replication/SystemTableWALEntryFilter.html" title="class in org.apache.hadoop.hbase.replication"><span class="typeNameLink">Prev Class</span></a></li> <li><a href="../../../../../org/apache/hadoop/hbase/replication/WALEntryFilter.html" title="interface in org.apache.hadoop.hbase.replication"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList">
