http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f68717a0/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html b/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html index eee0f8c..9c58b1f 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html @@ -92,9 +92,10 @@ <hr> <br> <pre><a href="../../../../../org/apache/hadoop/hbase/classification/InterfaceAudience.Private.html" title="annotation in org.apache.hadoop.hbase.classification">@InterfaceAudience.Private</a> -public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#line.31">ReplicationQueuesClient</a></pre> +public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#line.32">ReplicationQueuesClient</a></pre> <div class="block">This provides an interface for clients of replication to view replication queues. These queues - keep track of the WALs that still need to be replicated to remote clusters.</div> + keep track of the sources(WALs/HFile references) that still need to be replicated to remote + clusters.</div> </li> </ul> </div> @@ -115,10 +116,22 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic </tr> <tr class="altColor"> <td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/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/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>></code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#getAllPeersFromHFileRefsQueue()">getAllPeersFromHFileRefsQueue</a></strong>()</code> +<div class="block">Get list of all peers from hfile reference queue.</div> +</td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/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/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#getAllQueues(java.lang.String)">getAllQueues</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> serverName)</code> <div class="block">Get a list of all queues for the specified region server.</div> </td> </tr> +<tr class="altColor"> +<td class="colFirst"><code>int</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#getHFileRefsNodeChangeVersion()">getHFileRefsNodeChangeVersion</a></strong>()</code> +<div class="block">Get the change version number of replication hfile references node.</div> +</td> +</tr> <tr class="rowColor"> <td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/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/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#getListOfReplicators()">getListOfReplicators</a></strong>()</code> @@ -139,6 +152,12 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic </td> </tr> <tr class="altColor"> +<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/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/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>></code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#getReplicableHFiles(java.lang.String)">getReplicableHFiles</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> peerId)</code> +<div class="block">Get a list of all hfile references in the given peer.</div> +</td> +</tr> +<tr class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#init()">init</a></strong>()</code> <div class="block">Initialize the replication queue client interface.</div> @@ -165,7 +184,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic <ul class="blockList"> <li class="blockList"> <h4>init</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#line.36">init</a>() +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#line.37">init</a>() throws <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> <div class="block">Initialize the replication queue client interface.</div> <dl><dt><span class="strong">Throws:</span></dt> @@ -178,7 +197,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic <ul class="blockList"> <li class="blockList"> <h4>getListOfReplicators</h4> -<pre><a href="http://docs.oracle.com/javase/7/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/7/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/ReplicationQueuesClient.html#line.44">getListOfReplicators</a>() +<pre><a href="http://docs.oracle.com/javase/7/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/7/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/ReplicationQueuesClient.html#line.45">getListOfReplicators</a>() throws org.apache.zookeeper.KeeperException</pre> <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> @@ -193,7 +212,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic <ul class="blockList"> <li class="blockList"> <h4>getLogsInQueue</h4> -<pre><a href="http://docs.oracle.com/javase/7/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/7/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/ReplicationQueuesClient.html#line.53">getLogsInQueue</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> serverName, +<pre><a href="http://docs.oracle.com/javase/7/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/7/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/ReplicationQueuesClient.html#line.54">getLogsInQueue</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> serverName, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId) throws org.apache.zookeeper.KeeperException</pre> <div class="block">Get a list of all WALs in the given queue on the given region server.</div> @@ -209,7 +228,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic <ul class="blockList"> <li class="blockList"> <h4>getAllQueues</h4> -<pre><a href="http://docs.oracle.com/javase/7/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/7/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/ReplicationQueuesClient.html#line.60">getAllQueues</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> serverName) +<pre><a href="http://docs.oracle.com/javase/7/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/7/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/ReplicationQueuesClient.html#line.61">getAllQueues</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> serverName) throws org.apache.zookeeper.KeeperException</pre> <div class="block">Get a list of all queues for the specified region server.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>serverName</code> - the server name of the region server that owns the set of queues</dd> @@ -221,10 +240,10 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic <a name="getQueuesZNodeCversion()"> <!-- --> </a> -<ul class="blockListLast"> +<ul class="blockList"> <li class="blockList"> <h4>getQueuesZNodeCversion</h4> -<pre>int <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#line.67">getQueuesZNodeCversion</a>() +<pre>int <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#line.68">getQueuesZNodeCversion</a>() throws org.apache.zookeeper.KeeperException</pre> <div class="block">Get the cversion of replication rs node. This can be used as optimistic locking to get a consistent snapshot of the replication queues.</div> @@ -233,6 +252,50 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic <dd><code>org.apache.zookeeper.KeeperException</code></dd></dl> </li> </ul> +<a name="getHFileRefsNodeChangeVersion()"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getHFileRefsNodeChangeVersion</h4> +<pre>int <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#line.75">getHFileRefsNodeChangeVersion</a>() + throws org.apache.zookeeper.KeeperException</pre> +<div class="block">Get the change version number of replication hfile references node. This can be used as + optimistic locking to get a consistent snapshot of the replication queues of hfile references.</div> +<dl><dt><span class="strong">Returns:</span></dt><dd>change version number of hfile references node</dd> +<dt><span class="strong">Throws:</span></dt> +<dd><code>org.apache.zookeeper.KeeperException</code></dd></dl> +</li> +</ul> +<a name="getAllPeersFromHFileRefsQueue()"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getAllPeersFromHFileRefsQueue</h4> +<pre><a href="http://docs.oracle.com/javase/7/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/7/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/ReplicationQueuesClient.html#line.82">getAllPeersFromHFileRefsQueue</a>() + throws org.apache.zookeeper.KeeperException</pre> +<div class="block">Get list of all peers from hfile reference queue.</div> +<dl><dt><span class="strong">Returns:</span></dt><dd>a list of peer ids</dd> +<dt><span class="strong">Throws:</span></dt> +<dd><code>org.apache.zookeeper.KeeperException</code> - zookeeper exception</dd></dl> +</li> +</ul> +<a name="getReplicableHFiles(java.lang.String)"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>getReplicableHFiles</h4> +<pre><a href="http://docs.oracle.com/javase/7/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/7/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/ReplicationQueuesClient.html#line.90">getReplicableHFiles</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> peerId) + throws org.apache.zookeeper.KeeperException</pre> +<div class="block">Get a list of all hfile references in the given peer.</div> +<dl><dt><span class="strong">Parameters:</span></dt><dd><code>peerId</code> - a String that identifies the peer</dd> +<dt><span class="strong">Returns:</span></dt><dd>a list of hfile references, null if not found any</dd> +<dt><span class="strong">Throws:</span></dt> +<dd><code>org.apache.zookeeper.KeeperException</code> - zookeeper exception</dd></dl> +</li> +</ul> </li> </ul> </li>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f68717a0/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueuesClientZKImpl.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueuesClientZKImpl.html b/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueuesClientZKImpl.html index a669294..badf906 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueuesClientZKImpl.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueuesClientZKImpl.html @@ -125,7 +125,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <!-- --> </a> <h3>Fields inherited from class org.apache.hadoop.hbase.replication.<a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html" title="class in org.apache.hadoop.hbase.replication">ReplicationStateZKBase</a></h3> -<code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#abortable">abortable</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#conf">conf</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#DISABLED_ZNODE_BYTES">DISABLED_ZNODE_BYTES</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#ENABLED_ZNODE_BYTES">ENABLED_ZNODE_BYTES</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#ourClusterKey">ourClusterKey</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#peerStateNodeName">peerStateNodeName</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#peersZNode">peersZNode</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#queuesZNode">queuesZNode</a>, <a href="../../.. /../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#replicationZNode">replicationZNode</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#zookeeper">zookeeper</a></code></li> +<code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#abortable">abortable</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#conf">conf</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#DISABLED_ZNODE_BYTES">DISABLED_ZNODE_BYTES</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#ENABLED_ZNODE_BYTES">ENABLED_ZNODE_BYTES</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#hfileRefsZNode">hfileRefsZNode</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#ourClusterKey">ourClusterKey</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#peerStateNodeName">peerStateNodeName</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#peersZNode">peersZNode</a>, <a href=".. /../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#queuesZNode">queuesZNode</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#replicationForBulkLoadEnabled">replicationForBulkLoadEnabled</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#replicationZNode">replicationZNode</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#zookeeper">zookeeper</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT">ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY">ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY</a></code></li> </ul> </li> </ul> @@ -162,10 +162,22 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati </tr> <tr class="altColor"> <td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/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/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>></code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClientZKImpl.html#getAllPeersFromHFileRefsQueue()">getAllPeersFromHFileRefsQueue</a></strong>()</code> +<div class="block">Get list of all peers from hfile reference queue.</div> +</td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/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/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClientZKImpl.html#getAllQueues(java.lang.String)">getAllQueues</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> serverName)</code> <div class="block">Get a list of all queues for the specified region server.</div> </td> </tr> +<tr class="altColor"> +<td class="colFirst"><code>int</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClientZKImpl.html#getHFileRefsNodeChangeVersion()">getHFileRefsNodeChangeVersion</a></strong>()</code> +<div class="block">Get the change version number of replication hfile references node.</div> +</td> +</tr> <tr class="rowColor"> <td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/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/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClientZKImpl.html#getLogsInQueue(java.lang.String,%20java.lang.String)">getLogsInQueue</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> serverName, @@ -180,6 +192,12 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati </td> </tr> <tr class="rowColor"> +<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/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/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>></code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClientZKImpl.html#getReplicableHFiles(java.lang.String)">getReplicableHFiles</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> peerId)</code> +<div class="block">Get a list of all hfile references in the given peer.</div> +</td> +</tr> +<tr class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClientZKImpl.html#init()">init</a></strong>()</code> <div class="block">Initialize the replication queue client interface.</div> @@ -299,7 +317,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <a name="getQueuesZNodeCversion()"> <!-- --> </a> -<ul class="blockListLast"> +<ul class="blockList"> <li class="blockList"> <h4>getQueuesZNodeCversion</h4> <pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesClientZKImpl.html#line.77">getQueuesZNodeCversion</a>() @@ -315,6 +333,62 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <dd><code>org.apache.zookeeper.KeeperException</code></dd></dl> </li> </ul> +<a name="getHFileRefsNodeChangeVersion()"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getHFileRefsNodeChangeVersion</h4> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesClientZKImpl.html#line.89">getHFileRefsNodeChangeVersion</a>() + throws org.apache.zookeeper.KeeperException</pre> +<div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#getHFileRefsNodeChangeVersion()">ReplicationQueuesClient</a></code></strong></div> +<div class="block">Get the change version number of replication hfile references node. This can be used as + optimistic locking to get a consistent snapshot of the replication queues of hfile references.</div> +<dl> +<dt><strong>Specified by:</strong></dt> +<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#getHFileRefsNodeChangeVersion()">getHFileRefsNodeChangeVersion</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueuesClient</a></code></dd> +<dt><span class="strong">Returns:</span></dt><dd>change version number of hfile references node</dd> +<dt><span class="strong">Throws:</span></dt> +<dd><code>org.apache.zookeeper.KeeperException</code></dd></dl> +</li> +</ul> +<a name="getAllPeersFromHFileRefsQueue()"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getAllPeersFromHFileRefsQueue</h4> +<pre>public <a href="http://docs.oracle.com/javase/7/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/7/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/ReplicationQueuesClientZKImpl.html#line.101">getAllPeersFromHFileRefsQueue</a>() + throws org.apache.zookeeper.KeeperException</pre> +<div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#getAllPeersFromHFileRefsQueue()">ReplicationQueuesClient</a></code></strong></div> +<div class="block">Get list of all peers from hfile reference queue.</div> +<dl> +<dt><strong>Specified by:</strong></dt> +<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#getAllPeersFromHFileRefsQueue()">getAllPeersFromHFileRefsQueue</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueuesClient</a></code></dd> +<dt><span class="strong">Returns:</span></dt><dd>a list of peer ids</dd> +<dt><span class="strong">Throws:</span></dt> +<dd><code>org.apache.zookeeper.KeeperException</code> - zookeeper exception</dd></dl> +</li> +</ul> +<a name="getReplicableHFiles(java.lang.String)"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>getReplicableHFiles</h4> +<pre>public <a href="http://docs.oracle.com/javase/7/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/7/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/ReplicationQueuesClientZKImpl.html#line.113">getReplicableHFiles</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> peerId) + throws org.apache.zookeeper.KeeperException</pre> +<div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#getReplicableHFiles(java.lang.String)">ReplicationQueuesClient</a></code></strong></div> +<div class="block">Get a list of all hfile references in the given peer.</div> +<dl> +<dt><strong>Specified by:</strong></dt> +<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html#getReplicableHFiles(java.lang.String)">getReplicableHFiles</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueuesClient</a></code></dd> +<dt><span class="strong">Parameters:</span></dt><dd><code>peerId</code> - a String that identifies the peer</dd> +<dt><span class="strong">Returns:</span></dt><dd>a list of hfile references, null if not found any</dd> +<dt><span class="strong">Throws:</span></dt> +<dd><code>org.apache.zookeeper.KeeperException</code> - zookeeper exception</dd></dl> +</li> +</ul> </li> </ul> </li> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f68717a0/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html b/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html index a2d40cc..35da295 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html @@ -167,7 +167,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <!-- --> </a> <h3>Fields inherited from class org.apache.hadoop.hbase.replication.<a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html" title="class in org.apache.hadoop.hbase.replication">ReplicationStateZKBase</a></h3> -<code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#abortable">abortable</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#conf">conf</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#DISABLED_ZNODE_BYTES">DISABLED_ZNODE_BYTES</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#ENABLED_ZNODE_BYTES">ENABLED_ZNODE_BYTES</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#ourClusterKey">ourClusterKey</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#peerStateNodeName">peerStateNodeName</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#peersZNode">peersZNode</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#queuesZNode">queuesZNode</a>, <a href="../../.. /../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#replicationZNode">replicationZNode</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#zookeeper">zookeeper</a></code></li> +<code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#abortable">abortable</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#conf">conf</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#DISABLED_ZNODE_BYTES">DISABLED_ZNODE_BYTES</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#ENABLED_ZNODE_BYTES">ENABLED_ZNODE_BYTES</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#hfileRefsZNode">hfileRefsZNode</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#ourClusterKey">ourClusterKey</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#peerStateNodeName">peerStateNodeName</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#peersZNode">peersZNode</a>, <a href=".. /../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#queuesZNode">queuesZNode</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#replicationForBulkLoadEnabled">replicationForBulkLoadEnabled</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#replicationZNode">replicationZNode</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#zookeeper">zookeeper</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT">ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT</a>, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY">ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY</a></code></li> </ul> </li> </ul> @@ -204,11 +204,24 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati </tr> <tr class="altColor"> <td class="colFirst"><code>void</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#addHFileRefs(java.lang.String,%20java.util.List)">addHFileRefs</a></strong>(<a href="http://docs.oracle.com/javase/7/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/7/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/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> files)</code> +<div class="block">Add new hfile references to the queue.</div> +</td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#addLog(java.lang.String,%20java.lang.String)">addLog</a></strong>(<a href="http://docs.oracle.com/javase/7/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/7/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 class="altColor"> +<td class="colFirst"><code>void</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#addPeerToHFileRefs(java.lang.String)">addPeerToHFileRefs</a></strong>(<a href="http://docs.oracle.com/javase/7/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 class="rowColor"> <td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/SortedMap.html?is-external=true"; title="class or interface in java.util">SortedMap</a><<a href="http://docs.oracle.com/javase/7/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/7/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/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>>></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#claimQueues(java.lang.String)">claimQueues</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> regionserverZnode)</code> @@ -284,18 +297,25 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati </tr> <tr class="rowColor"> <td class="colFirst"><code>void</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#removeHFileRefs(java.lang.String,%20java.util.List)">removeHFileRefs</a></strong>(<a href="http://docs.oracle.com/javase/7/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/7/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/7/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 class="altColor"> +<td class="colFirst"><code>void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#removeLog(java.lang.String,%20java.lang.String)">removeLog</a></strong>(<a href="http://docs.oracle.com/javase/7/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/7/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 class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#removeQueue(java.lang.String)">removeQueue</a></strong>(<a href="http://docs.oracle.com/javase/7/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 class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#setLogPosition(java.lang.String,%20java.lang.String,%20long)">setLogPosition</a></strong>(<a href="http://docs.oracle.com/javase/7/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/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> filename, @@ -421,7 +441,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>removeQueue</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.90">removeQueue</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.99">removeQueue</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId)</pre> <div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#removeQueue(java.lang.String)">ReplicationQueues</a></code></strong></div> <div class="block">Remove a replication queue.</div> <dl> @@ -436,7 +456,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>addLog</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.99">addLog</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId, +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.108">addLog</a>(<a href="http://docs.oracle.com/javase/7/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/7/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"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#addLog(java.lang.String,%20java.lang.String)">ReplicationQueues</a></code></strong></div> @@ -455,7 +475,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>removeLog</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.112">removeLog</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId, +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.121">removeLog</a>(<a href="http://docs.oracle.com/javase/7/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/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> filename)</pre> <div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#removeLog(java.lang.String,%20java.lang.String)">ReplicationQueues</a></code></strong></div> <div class="block">Remove an WAL file from the given queue.</div> @@ -471,7 +491,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>setLogPosition</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.124">setLogPosition</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId, +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.133">setLogPosition</a>(<a href="http://docs.oracle.com/javase/7/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/7/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"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#setLogPosition(java.lang.String,%20java.lang.String,%20long)">ReplicationQueues</a></code></strong></div> @@ -488,7 +508,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>getLogPosition</h4> -<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.137">getLogPosition</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId, +<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.146">getLogPosition</a>(<a href="http://docs.oracle.com/javase/7/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/7/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"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#getLogPosition(java.lang.String,%20java.lang.String)">ReplicationQueues</a></code></strong></div> @@ -508,7 +528,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>isThisOurZnode</h4> -<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.162">isThisOurZnode</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> znode)</pre> +<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.171">isThisOurZnode</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> znode)</pre> <div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#isThisOurZnode(java.lang.String)">ReplicationQueues</a></code></strong></div> <div class="block">Checks if the provided znode is the same as this region server's</div> <dl> @@ -524,7 +544,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>claimQueues</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/SortedMap.html?is-external=true"; title="class or interface in java.util">SortedMap</a><<a href="http://docs.oracle.com/javase/7/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/7/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/7/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/ReplicationQueuesZKImpl.html#line.167">claimQueues</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> regionserverZnode)</pre> +<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/SortedMap.html?is-external=true"; title="class or interface in java.util">SortedMap</a><<a href="http://docs.oracle.com/javase/7/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/7/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/7/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/ReplicationQueuesZKImpl.html#line.176">claimQueues</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> regionserverZnode)</pre> <div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#claimQueues(java.lang.String)">ReplicationQueues</a></code></strong></div> <div class="block">Take ownership for the set of queues belonging to a dead region server.</div> <dl> @@ -541,7 +561,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>removeAllQueues</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.185">removeAllQueues</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.194">removeAllQueues</a>()</pre> <div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#removeAllQueues()">ReplicationQueues</a></code></strong></div> <div class="block">Remove all replication queues for this region server.</div> <dl> @@ -556,7 +576,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>getLogsInQueue</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/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/7/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/ReplicationQueuesZKImpl.html#line.199">getLogsInQueue</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId)</pre> +<pre>public <a href="http://docs.oracle.com/javase/7/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/7/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/ReplicationQueuesZKImpl.html#line.208">getLogsInQueue</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> queueId)</pre> <div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#getLogsInQueue(java.lang.String)">ReplicationQueues</a></code></strong></div> <div class="block">Get a list of all WALs in the given queue.</div> <dl> @@ -572,7 +592,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>getAllQueues</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/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/7/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/ReplicationQueuesZKImpl.html#line.211">getAllQueues</a>()</pre> +<pre>public <a href="http://docs.oracle.com/javase/7/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/7/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/ReplicationQueuesZKImpl.html#line.220">getAllQueues</a>()</pre> <div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#getAllQueues()">ReplicationQueues</a></code></strong></div> <div class="block">Get a list of all queues for this region server.</div> <dl> @@ -587,7 +607,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>lockOtherRS</h4> -<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.227">lockOtherRS</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> znode)</pre> +<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.236">lockOtherRS</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> znode)</pre> <div class="block">Try to set a lock in another region server's znode.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>znode</code> - the server names of the other server</dd> <dt><span class="strong">Returns:</span></dt><dd>true if the lock was acquired, false in every other cases</dd></dl> @@ -599,7 +619,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>deleteAnotherRSQueues</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.258">deleteAnotherRSQueues</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> regionserverZnode)</pre> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.267">deleteAnotherRSQueues</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> regionserverZnode)</pre> <div class="block">Delete all the replication queues for a given region server.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>regionserverZnode</code> - The znode of the region server to delete.</dd></dl> </li> @@ -610,7 +630,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>copyQueuesFromRSUsingMulti</h4> -<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/SortedMap.html?is-external=true"; title="class or interface in java.util">SortedMap</a><<a href="http://docs.oracle.com/javase/7/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/7/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/7/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/ReplicationQueuesZKImpl.html#line.293">copyQueuesFromRSUsingMulti</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> znode)</pre> +<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/SortedMap.html?is-external=true"; title="class or interface in java.util">SortedMap</a><<a href="http://docs.oracle.com/javase/7/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/7/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/7/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/ReplicationQueuesZKImpl.html#line.302">copyQueuesFromRSUsingMulti</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> znode)</pre> <div class="block">It "atomically" copies all the wals queues from another region server and returns them all sorted per peer cluster (appended with the dead server's znode).</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>znode</code> - pertaining to the region server to copy the queues from</dd> @@ -623,7 +643,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>copyQueuesFromRS</h4> -<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/SortedMap.html?is-external=true"; title="class or interface in java.util">SortedMap</a><<a href="http://docs.oracle.com/javase/7/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/7/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/7/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/ReplicationQueuesZKImpl.html#line.362">copyQueuesFromRS</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> znode)</pre> +<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/SortedMap.html?is-external=true"; title="class or interface in java.util">SortedMap</a><<a href="http://docs.oracle.com/javase/7/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/7/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/7/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/ReplicationQueuesZKImpl.html#line.371">copyQueuesFromRS</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> znode)</pre> <div class="block">This methods copies all the wals queues from another region server and returns them all sorted per peer cluster (appended with the dead server's znode)</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>znode</code> - server names to copy</dd> @@ -633,15 +653,68 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <a name="lockToByteArray(java.lang.String)"> <!-- --> </a> -<ul class="blockListLast"> +<ul class="blockList"> <li class="blockList"> <h4>lockToByteArray</h4> -<pre>static byte[] <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.429">lockToByteArray</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> lockOwner)</pre> +<pre>static byte[] <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.438">lockToByteArray</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> lockOwner)</pre> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>lockOwner</code> - </dd> <dt><span class="strong">Returns:</span></dt><dd>Serialized protobuf of <code>lockOwner</code> with pb magic prefix prepended suitable for use as content of an replication lock during region server fail over.</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/ReplicationQueuesZKImpl.html#line.445">addHFileRefs</a>(<a href="http://docs.oracle.com/javase/7/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/7/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/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> files) + throws <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> +<div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#addHFileRefs(java.lang.String,%20java.util.List)">ReplicationQueues</a></code></strong></div> +<div class="block">Add new hfile references to the queue.</div> +<dl> +<dt><strong>Specified by:</strong></dt> +<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#addHFileRefs(java.lang.String,%20java.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="strong">Parameters:</span></dt><dd><code>peerId</code> - peer cluster id to which the hfiles need to be replicated</dd><dd><code>files</code> - list of hfile references to be added</dd> +<dt><span class="strong">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/ReplicationQueuesZKImpl.html#line.469">removeHFileRefs</a>(<a href="http://docs.oracle.com/javase/7/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/7/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/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> files)</pre> +<div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#removeHFileRefs(java.lang.String,%20java.util.List)">ReplicationQueues</a></code></strong></div> +<div class="block">Remove hfile references from the queue.</div> +<dl> +<dt><strong>Specified by:</strong></dt> +<dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#removeHFileRefs(java.lang.String,%20java.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="strong">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="addPeerToHFileRefs(java.lang.String)"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>addPeerToHFileRefs</h4> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueuesZKImpl.html#line.492">addPeerToHFileRefs</a>(<a href="http://docs.oracle.com/javase/7/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"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.html#addPeerToHFileRefs(java.lang.String)">ReplicationQueues</a></code></strong></div> +<div class="block">Add a peer to hfile reference queue if peer does not exist.</div> +<dl> +<dt><strong>Specified by:</strong></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="strong">Parameters:</span></dt><dd><code>peerId</code> - peer cluster id to be added</dd> +<dt><span class="strong">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> </li> </ul> </li> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f68717a0/devapidocs/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html b/devapidocs/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html index 4fbcf63..a838fd0 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html @@ -100,7 +100,7 @@ <hr> <br> <pre><a href="../../../../../org/apache/hadoop/hbase/classification/InterfaceAudience.Private.html" title="annotation in org.apache.hadoop.hbase.classification">@InterfaceAudience.Private</a> -public abstract class <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.37">ReplicationStateZKBase</a> +public abstract class <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.39">ReplicationStateZKBase</a> extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a></pre> <div class="block">This is a base class for maintaining replication state in zookeeper.</div> </li> @@ -139,28 +139,38 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? </tr> <tr class="altColor"> <td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#hfileRefsZNode">hfileRefsZNode</a></strong></code> +<div class="block">The name of the znode that contains queues of hfile references to be replicated</div> +</td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#ourClusterKey">ourClusterKey</a></strong></code> <div class="block">The cluster key of the local cluster</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#peerStateNodeName">peerStateNodeName</a></strong></code> <div class="block">The name of the znode that contains the replication status of a remote slave (i.e.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#peersZNode">peersZNode</a></strong></code> <div class="block">The name of the znode that contains a list of all remote slave (i.e.</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#queuesZNode">queuesZNode</a></strong></code> <div class="block">The name of the znode that contains all replication queues</div> </td> </tr> +<tr class="rowColor"> +<td class="colFirst"><code>protected boolean</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#replicationForBulkLoadEnabled">replicationForBulkLoadEnabled</a></strong></code> </td> +</tr> <tr class="altColor"> <td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#replicationZNode">replicationZNode</a></strong></code> @@ -171,6 +181,14 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <td class="colFirst"><code>protected <a href="../../../../../org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.html" title="class in org.apache.hadoop.hbase.zookeeper">ZooKeeperWatcher</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#zookeeper">zookeeper</a></strong></code> </td> </tr> +<tr class="altColor"> +<td class="colFirst"><code>static <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT">ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT</a></strong></code> </td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>static <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY">ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY</a></strong></code> </td> +</tr> </table> </li> </ul> @@ -251,7 +269,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>peerStateNodeName</h4> -<pre>protected final <a href="http://docs.oracle.com/javase/7/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/ReplicationStateZKBase.html#line.43">peerStateNodeName</a></pre> +<pre>protected final <a href="http://docs.oracle.com/javase/7/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/ReplicationStateZKBase.html#line.45">peerStateNodeName</a></pre> <div class="block">The name of the znode that contains the replication status of a remote slave (i.e. peer) cluster.</div> </li> @@ -262,7 +280,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>replicationZNode</h4> -<pre>protected final <a href="http://docs.oracle.com/javase/7/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/ReplicationStateZKBase.html#line.45">replicationZNode</a></pre> +<pre>protected final <a href="http://docs.oracle.com/javase/7/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/ReplicationStateZKBase.html#line.47">replicationZNode</a></pre> <div class="block">The name of the base znode that contains all replication state.</div> </li> </ul> @@ -272,7 +290,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>peersZNode</h4> -<pre>protected final <a href="http://docs.oracle.com/javase/7/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/ReplicationStateZKBase.html#line.47">peersZNode</a></pre> +<pre>protected final <a href="http://docs.oracle.com/javase/7/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/ReplicationStateZKBase.html#line.49">peersZNode</a></pre> <div class="block">The name of the znode that contains a list of all remote slave (i.e. peer) clusters.</div> </li> </ul> @@ -282,17 +300,27 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>queuesZNode</h4> -<pre>protected final <a href="http://docs.oracle.com/javase/7/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/ReplicationStateZKBase.html#line.49">queuesZNode</a></pre> +<pre>protected final <a href="http://docs.oracle.com/javase/7/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/ReplicationStateZKBase.html#line.51">queuesZNode</a></pre> <div class="block">The name of the znode that contains all replication queues</div> </li> </ul> +<a name="hfileRefsZNode"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>hfileRefsZNode</h4> +<pre>protected final <a href="http://docs.oracle.com/javase/7/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/ReplicationStateZKBase.html#line.53">hfileRefsZNode</a></pre> +<div class="block">The name of the znode that contains queues of hfile references to be replicated</div> +</li> +</ul> <a name="ourClusterKey"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>ourClusterKey</h4> -<pre>protected final <a href="http://docs.oracle.com/javase/7/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/ReplicationStateZKBase.html#line.51">ourClusterKey</a></pre> +<pre>protected final <a href="http://docs.oracle.com/javase/7/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/ReplicationStateZKBase.html#line.55">ourClusterKey</a></pre> <div class="block">The cluster key of the local cluster</div> </li> </ul> @@ -302,7 +330,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>zookeeper</h4> -<pre>protected final <a href="../../../../../org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.html" title="class in org.apache.hadoop.hbase.zookeeper">ZooKeeperWatcher</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.52">zookeeper</a></pre> +<pre>protected final <a href="../../../../../org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.html" title="class in org.apache.hadoop.hbase.zookeeper">ZooKeeperWatcher</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.56">zookeeper</a></pre> </li> </ul> <a name="conf"> @@ -311,7 +339,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>conf</h4> -<pre>protected final org.apache.hadoop.conf.Configuration <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.53">conf</a></pre> +<pre>protected final org.apache.hadoop.conf.Configuration <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.57">conf</a></pre> </li> </ul> <a name="abortable"> @@ -320,7 +348,16 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>abortable</h4> -<pre>protected final <a href="../../../../../org/apache/hadoop/hbase/Abortable.html" title="interface in org.apache.hadoop.hbase">Abortable</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.54">abortable</a></pre> +<pre>protected final <a href="../../../../../org/apache/hadoop/hbase/Abortable.html" title="interface in org.apache.hadoop.hbase">Abortable</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.58">abortable</a></pre> +</li> +</ul> +<a name="replicationForBulkLoadEnabled"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>replicationForBulkLoadEnabled</h4> +<pre>protected final boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.59">replicationForBulkLoadEnabled</a></pre> </li> </ul> <a name="ENABLED_ZNODE_BYTES"> @@ -329,16 +366,36 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>ENABLED_ZNODE_BYTES</h4> -<pre>public static final byte[] <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.57">ENABLED_ZNODE_BYTES</a></pre> +<pre>public static final byte[] <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.62">ENABLED_ZNODE_BYTES</a></pre> </li> </ul> <a name="DISABLED_ZNODE_BYTES"> <!-- --> </a> -<ul class="blockListLast"> +<ul class="blockList"> <li class="blockList"> <h4>DISABLED_ZNODE_BYTES</h4> -<pre>public static final byte[] <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.59">DISABLED_ZNODE_BYTES</a></pre> +<pre>public static final byte[] <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.64">DISABLED_ZNODE_BYTES</a></pre> +</li> +</ul> +<a name="ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY</h4> +<pre>public static final <a href="http://docs.oracle.com/javase/7/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/ReplicationStateZKBase.html#line.66">ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY</a></pre> +<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.replication.ReplicationStateZKBase.ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY">Constant Field Values</a></dd></dl> +</li> +</ul> +<a name="ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT</h4> +<pre>public static final <a href="http://docs.oracle.com/javase/7/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/ReplicationStateZKBase.html#line.68">ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT</a></pre> +<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.replication.ReplicationStateZKBase.ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT">Constant Field Values</a></dd></dl> </li> </ul> </li> @@ -355,7 +412,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>ReplicationStateZKBase</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.62">ReplicationStateZKBase</a>(<a href="../../../../../org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.html" title="class in org.apache.hadoop.hbase.zookeeper">ZooKeeperWatcher</a> zookeeper, +<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.70">ReplicationStateZKBase</a>(<a href="../../../../../org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.html" title="class in org.apache.hadoop.hbase.zookeeper">ZooKeeperWatcher</a> zookeeper, org.apache.hadoop.conf.Configuration conf, <a href="../../../../../org/apache/hadoop/hbase/Abortable.html" title="interface in org.apache.hadoop.hbase">Abortable</a> abortable)</pre> </li> @@ -374,7 +431,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getListOfReplicators</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/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/7/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/ReplicationStateZKBase.html#line.78">getListOfReplicators</a>()</pre> +<pre>public <a href="http://docs.oracle.com/javase/7/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/7/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/ReplicationStateZKBase.html#line.91">getListOfReplicators</a>()</pre> </li> </ul> <a name="toByteArray(org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.ReplicationState.State)"> @@ -383,7 +440,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>toByteArray</h4> -<pre>protected static byte[] <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.94">toByteArray</a>(org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.ReplicationState.State state)</pre> +<pre>protected static byte[] <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.107">toByteArray</a>(org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.ReplicationState.State state)</pre> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>state</code> - </dd> <dt><span class="strong">Returns:</span></dt><dd>Serialized protobuf of <code>state</code> with pb magic prefix prepended suitable for use as content of a peer-state znode under a peer cluster id as in @@ -396,7 +453,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>peerExists</h4> -<pre>protected boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.100">peerExists</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id) +<pre>protected boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.113">peerExists</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id) throws org.apache.zookeeper.KeeperException</pre> <dl><dt><span class="strong">Throws:</span></dt> <dd><code>org.apache.zookeeper.KeeperException</code></dd></dl> @@ -408,7 +465,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>isPeerPath</h4> -<pre>protected boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.109">isPeerPath</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> path)</pre> +<pre>protected boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html#line.122">isPeerPath</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> path)</pre> <div class="block">Determine if a ZK path points to a peer node.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>path</code> - path to be checked</dd> <dt><span class="strong">Returns:</span></dt><dd>true if the path points to a peer node, otherwise false</dd></dl>
