http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f68717a0/devapidocs/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html b/devapidocs/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html index 1f021b6..e73b2ef 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html @@ -105,7 +105,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 class <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.79">ReplicationPeersZKImpl</a> +public class <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.81">ReplicationPeersZKImpl</a> extends <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationStateZKBase.html" title="class in org.apache.hadoop.hbase.replication">ReplicationStateZKBase</a> implements <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationPeers</a></pre> <div class="block">This class provides an implementation of the ReplicationPeers interface using Zookeeper. The @@ -172,7 +172,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> @@ -405,7 +405,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>peerClusters</h4> -<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</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="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerZKImpl.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerZKImpl</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.82">peerClusters</a></pre> +<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</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="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerZKImpl.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerZKImpl</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.84">peerClusters</a></pre> </li> </ul> <a name="tableCFsNodeName"> @@ -414,7 +414,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>tableCFsNodeName</h4> -<pre>private 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/ReplicationPeersZKImpl.html#line.83">tableCFsNodeName</a></pre> +<pre>private 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/ReplicationPeersZKImpl.html#line.85">tableCFsNodeName</a></pre> </li> </ul> <a name="queuesClient"> @@ -423,7 +423,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>queuesClient</h4> -<pre>private final <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueuesClient</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.84">queuesClient</a></pre> +<pre>private final <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueuesClient</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.86">queuesClient</a></pre> </li> </ul> <a name="LOG"> @@ -432,7 +432,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockListLast"> <li class="blockList"> <h4>LOG</h4> -<pre>private static final org.apache.commons.logging.Log <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.86">LOG</a></pre> +<pre>private static final org.apache.commons.logging.Log <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.88">LOG</a></pre> </li> </ul> </li> @@ -449,7 +449,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockListLast"> <li class="blockList"> <h4>ReplicationPeersZKImpl</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.88">ReplicationPeersZKImpl</a>(<a href="../../../../../org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.html" title="class in org.apache.hadoop.hbase.zookeeper">ZooKeeperWatcher</a> zk, +<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.90">ReplicationPeersZKImpl</a>(<a href="../../../../../org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.html" title="class in org.apache.hadoop.hbase.zookeeper">ZooKeeperWatcher</a> zk, org.apache.hadoop.conf.Configuration conf, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueuesClient.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationQueuesClient</a> queuesClient, <a href="../../../../../org/apache/hadoop/hbase/Abortable.html" title="interface in org.apache.hadoop.hbase">Abortable</a> abortable)</pre> @@ -469,7 +469,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>init</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.97">init</a>() +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.99">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"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html#init()">ReplicationPeers</a></code></strong></div> <div class="block">Initialize the ReplicationPeers interface.</div> @@ -486,7 +486,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>addPeer</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.109">addPeer</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>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.111">addPeer</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, <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a> peerConfig, <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> tableCFs) throws <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> @@ -496,7 +496,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <dt><strong>Specified by:</strong></dt> <dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html#addPeer(java.lang.String,%20org.apache.hadoop.hbase.replication.ReplicationPeerConfig,%20java.lang.String)">addPeer</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationPeers</a></code></dd> <dt><span class="strong">Parameters:</span></dt><dd><code>id</code> - a short that identifies the cluster</dd><dd><code>peerConfig</code> - configuration for the replication slave cluster</dd><dd><code>tableCFs</code> - the table and column-family list which will be replicated for this peer or null - for all table and column families</dd> + for all table and column families</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></dd></dl> </li> @@ -507,7 +507,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>removePeer</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.146">removePeer</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>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.161">removePeer</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 <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/ReplicationPeers.html#removePeer(java.lang.String)">ReplicationPeers</a></code></strong></div> <div class="block">Removes a remote slave cluster and stops the replication to it.</div> @@ -525,7 +525,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>enablePeer</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.159">enablePeer</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>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.184">enablePeer</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 <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/ReplicationPeers.html#enablePeer(java.lang.String)">ReplicationPeers</a></code></strong></div> <div class="block">Restart the replication to the specified remote slave cluster.</div> @@ -543,7 +543,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>disablePeer</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.165">disablePeer</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>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.190">disablePeer</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 <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/ReplicationPeers.html#disablePeer(java.lang.String)">ReplicationPeers</a></code></strong></div> <div class="block">Stop the replication to the specified remote slave cluster.</div> @@ -561,7 +561,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>getPeerTableCFsConfig</h4> -<pre>public <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/ReplicationPeersZKImpl.html#line.171">getPeerTableCFsConfig</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>public <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/ReplicationPeersZKImpl.html#line.196">getPeerTableCFsConfig</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 <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/ReplicationPeers.html#getPeerTableCFsConfig(java.lang.String)">ReplicationPeers</a></code></strong></div> <div class="block">Get the table and column-family list string of the peer from ZK.</div> @@ -579,7 +579,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>setPeerTableCFsConfig</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.187">setPeerTableCFsConfig</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>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.212">setPeerTableCFsConfig</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, <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> tableCFsStr) 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/ReplicationPeers.html#setPeerTableCFsConfig(java.lang.String,%20java.lang.String)">ReplicationPeers</a></code></strong></div> @@ -598,7 +598,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>getTableCFs</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a>,<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/ReplicationPeersZKImpl.html#line.207">getTableCFs</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>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a>,<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/ReplicationPeersZKImpl.html#line.232">getTableCFs</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 <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/IllegalArgumentException.html?is-external=true"; title="class or interface in java.lang">IllegalArgumentException</a></pre> <div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html#getTableCFs(java.lang.String)">ReplicationPeers</a></code></strong></div> <div class="block">Get the table and column-family-list map of the peer.</div> @@ -617,7 +617,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>getStatusOfPeer</h4> -<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.216">getStatusOfPeer</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> +<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.241">getStatusOfPeer</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> <div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html#getStatusOfPeer(java.lang.String)">ReplicationPeers</a></code></strong></div> <div class="block">Get the replication status for the specified connected remote slave cluster. The value might be read from cache, so it is recommended to @@ -636,7 +636,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>getStatusOfPeerFromBackingStore</h4> -<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.225">getStatusOfPeerFromBackingStore</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>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.250">getStatusOfPeerFromBackingStore</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 <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/ReplicationPeers.html#getStatusOfPeerFromBackingStore(java.lang.String)">ReplicationPeers</a></code></strong></div> <div class="block">Get the replication status for the specified remote slave cluster, which doesn't @@ -656,7 +656,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>getAllPeerConfigs</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</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="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.247">getAllPeerConfigs</a>()</pre> +<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</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="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.272">getAllPeerConfigs</a>()</pre> <div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html#getAllPeerConfigs()">ReplicationPeers</a></code></strong></div> <div class="block">List the cluster replication configs of all remote slave clusters (whether they are enabled/disabled or connected/disconnected).</div> @@ -672,7 +672,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>getPeer</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeer.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationPeer</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.270">getPeer</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)</pre> +<pre>public <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeer.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationPeer</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.295">getPeer</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)</pre> <div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html#getPeer(java.lang.String)">ReplicationPeers</a></code></strong></div> <div class="block">Returns the ReplicationPeer</div> <dl> @@ -688,7 +688,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>getPeerIds</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Set.html?is-external=true"; title="class or interface in java.util">Set</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/ReplicationPeersZKImpl.html#line.275">getPeerIds</a>()</pre> +<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Set.html?is-external=true"; title="class or interface in java.util">Set</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/ReplicationPeersZKImpl.html#line.300">getPeerIds</a>()</pre> <div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html#getPeerIds()">ReplicationPeers</a></code></strong></div> <div class="block">Returns the set of peerIds defined</div> <dl> @@ -703,7 +703,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>getReplicationPeerConfig</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.283">getReplicationPeerConfig</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) +<pre>public <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.308">getReplicationPeerConfig</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">Returns a ReplicationPeerConfig from the znode or null for the given peerId.</div> <dl> @@ -721,7 +721,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>getPeerConf</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><<a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a>,org.apache.hadoop.conf.Configuration> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.313">getPeerConf</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) +<pre>public <a href="../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><<a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a>,org.apache.hadoop.conf.Configuration> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.338">getPeerConf</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/ReplicationPeers.html#getPeerConf(java.lang.String)">ReplicationPeers</a></code></strong></div> <div class="block">Returns the configuration needed to talk to the remote slave cluster.</div> @@ -740,7 +740,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>getAllPeerIds</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/ReplicationPeersZKImpl.html#line.345">getAllPeerIds</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/ReplicationPeersZKImpl.html#line.368">getAllPeerIds</a>()</pre> <div class="block">List all registered peer clusters and set a watch on their znodes.</div> <dl> <dt><strong>Specified by:</strong></dt> @@ -754,7 +754,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>addExistingPeers</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.359">addExistingPeers</a>() +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.382">addExistingPeers</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">A private method used during initialization. This method attempts to add all registered peer clusters. This method does not set a watch on the peer cluster znodes.</div> @@ -768,7 +768,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>peerAdded</h4> -<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.374">peerAdded</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) +<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.397">peerAdded</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> <dl> <dt><strong>Specified by:</strong></dt> @@ -783,7 +783,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>peerRemoved</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.379">peerRemoved</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)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.402">peerRemoved</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)</pre> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html#peerRemoved(java.lang.String)">peerRemoved</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html" title="interface in org.apache.hadoop.hbase.replication">ReplicationPeers</a></code></dd> @@ -796,7 +796,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>createAndAddPeer</h4> -<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.391">createAndAddPeer</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) +<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.414">createAndAddPeer</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">Attempt to connect to a new remote slave cluster.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>peerId</code> - a short that identifies the cluster</dd> @@ -811,7 +811,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>getTableCFsNode</h4> -<pre>private <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/ReplicationPeersZKImpl.html#line.419">getTableCFsNode</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> +<pre>private <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/ReplicationPeersZKImpl.html#line.442">getTableCFsNode</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> </li> </ul> <a name="getPeerStateNode(java.lang.String)"> @@ -820,7 +820,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>getPeerStateNode</h4> -<pre>private <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/ReplicationPeersZKImpl.html#line.423">getPeerStateNode</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> +<pre>private <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/ReplicationPeersZKImpl.html#line.446">getPeerStateNode</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> </li> </ul> <a name="changePeerState(java.lang.String, org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.ReplicationState.State)"> @@ -829,7 +829,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>changePeerState</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.432">changePeerState</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>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.455">changePeerState</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, org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.ReplicationState.State state) throws <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> <div class="block">Update the state znode of a peer cluster.</div> @@ -844,7 +844,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>createPeer</h4> -<pre>private <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerZKImpl.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerZKImpl</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.460">createPeer</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) +<pre>private <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerZKImpl.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerZKImpl</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.483">createPeer</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">Helper method to connect to a peer</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>peerId</code> - peer's identifier</dd> @@ -859,7 +859,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>parsePeerFrom</h4> -<pre>private static <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.490">parsePeerFrom</a>(byte[] bytes) +<pre>private static <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.513">parsePeerFrom</a>(byte[] bytes) throws <a href="../../../../../org/apache/hadoop/hbase/exceptions/DeserializationException.html" title="class in org.apache.hadoop.hbase.exceptions">DeserializationException</a></pre> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>bytes</code> - Content of a peer znode.</dd> <dt><span class="strong">Returns:</span></dt><dd>ClusterKey parsed from the passed bytes.</dd> @@ -873,7 +873,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>convert</h4> -<pre>private static <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.512">convert</a>(org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.ReplicationPeer peer)</pre> +<pre>private static <a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.535">convert</a>(org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.ReplicationPeer peer)</pre> </li> </ul> <a name="convert(org.apache.hadoop.hbase.replication.ReplicationPeerConfig)"> @@ -882,7 +882,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>convert</h4> -<pre>private static org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.ReplicationPeer <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.531">convert</a>(<a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a> peerConfig)</pre> +<pre>private static org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.ReplicationPeer <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.554">convert</a>(<a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a> peerConfig)</pre> </li> </ul> <a name="toByteArray(org.apache.hadoop.hbase.replication.ReplicationPeerConfig)"> @@ -891,7 +891,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockList"> <li class="blockList"> <h4>toByteArray</h4> -<pre>private static byte[] <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.563">toByteArray</a>(<a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a> peerConfig)</pre> +<pre>private static byte[] <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.586">toByteArray</a>(<a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a> peerConfig)</pre> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>peerConfig</code> - </dd> <dt><span class="strong">Returns:</span></dt><dd>Serialized protobuf of <code>peerConfig</code> with pb magic prefix prepended suitable for use as content of a this.peersZNode; i.e. the content of PEER_ID znode under @@ -904,7 +904,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/replication/Replicati <ul class="blockListLast"> <li class="blockList"> <h4>checkQueuesDeleted</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.568">checkQueuesDeleted</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) +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.html#line.591">checkQueuesDeleted</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> <dl><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></dd></dl>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f68717a0/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueues.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueues.html b/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueues.html index 3c0a409..9844ccc 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueues.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/ReplicationQueues.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/ReplicationQueues.html#line.32">ReplicationQueues</a></pre> +public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.33">ReplicationQueues</a></pre> <div class="block">This provides an interface for maintaining a region server's replication queues. These queues - keep track of the WALs that still need to be replicated to remote clusters.</div> + keep track of the WALs and HFile references (if hbase.replication.bulkload.enabled is enabled) + that still need to be replicated to remote clusters.</div> </li> </ul> </div> @@ -115,11 +116,24 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic </tr> <tr class="altColor"> <td class="colFirst"><code>void</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.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/ReplicationQueues.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/ReplicationQueues.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/ReplicationQueues.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> regionserver)</code> @@ -171,18 +185,25 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic </tr> <tr class="rowColor"> <td class="colFirst"><code>void</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/replication/ReplicationQueues.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/ReplicationQueues.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/ReplicationQueues.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/ReplicationQueues.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, @@ -211,7 +232,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/ReplicationQueues.html#line.39">init</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>void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.40">init</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 <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 region server replication queue interface.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>serverName</code> - The server name of the region server that owns the replication queues this @@ -226,7 +247,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic <ul class="blockList"> <li class="blockList"> <h4>removeQueue</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.45">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>void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.46">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">Remove a replication queue.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>queueId</code> - a String that identifies the queue.</dd></dl> </li> @@ -237,7 +258,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic <ul class="blockList"> <li class="blockList"> <h4>addLog</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.52">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>void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.53">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">Add a new WAL file to the given queue. If the queue does not exist it is created.</div> @@ -252,7 +273,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic <ul class="blockList"> <li class="blockList"> <h4>removeLog</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.59">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>void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.60">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">Remove an WAL file from the given queue.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>queueId</code> - a String that identifies the queue.</dd><dd><code>filename</code> - name of the WAL</dd></dl> @@ -264,7 +285,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic <ul class="blockList"> <li class="blockList"> <h4>setLogPosition</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.67">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>void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.68">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">Set the current position for a specific WAL in a given queue.</div> @@ -277,7 +298,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic <ul class="blockList"> <li class="blockList"> <h4>getLogPosition</h4> -<pre>long <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.75">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>long <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.76">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">Get the current position for a specific WAL in a given queue.</div> @@ -293,7 +314,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic <ul class="blockList"> <li class="blockList"> <h4>removeAllQueues</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.80">removeAllQueues</a>()</pre> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.81">removeAllQueues</a>()</pre> <div class="block">Remove all replication queues for this region server.</div> </li> </ul> @@ -303,7 +324,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/ReplicationQueues.html#line.87">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><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/ReplicationQueues.html#line.88">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">Get a list of all WALs in the given queue.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>queueId</code> - a String that identifies the queue</dd> <dt><span class="strong">Returns:</span></dt><dd>a list of WALs, null if this region server is dead and has no outstanding queues</dd></dl> @@ -315,7 +336,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/ReplicationQueues.html#line.93">getAllQueues</a>()</pre> +<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/ReplicationQueues.html#line.94">getAllQueues</a>()</pre> <div class="block">Get a list of all queues for this region server.</div> <dl><dt><span class="strong">Returns:</span></dt><dd>a list of queueIds, null if this region server is dead and has no outstanding queues</dd></dl> </li> @@ -326,7 +347,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic <ul class="blockList"> <li class="blockList"> <h4>claimQueues</h4> -<pre><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/ReplicationQueues.html#line.101">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> regionserver)</pre> +<pre><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/ReplicationQueues.html#line.102">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> regionserver)</pre> <div class="block">Take ownership for the set of queues belonging to a dead region server.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>regionserver</code> - the id of the dead region server</dd> <dt><span class="strong">Returns:</span></dt><dd>A SortedMap of the queues that have been claimed, including a SortedSet of WALs in @@ -339,7 +360,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/ReplicationQueues.html#line.108">getListOfReplicators</a>()</pre> +<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/ReplicationQueues.html#line.109">getListOfReplicators</a>()</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> <dl><dt><span class="strong">Returns:</span></dt><dd>a list of server names</dd></dl> @@ -348,15 +369,56 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/replic <a name="isThisOurZnode(java.lang.String)"> <!-- --> </a> -<ul class="blockListLast"> +<ul class="blockList"> <li class="blockList"> <h4>isThisOurZnode</h4> -<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.115">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>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.116">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">Checks if the provided znode is the same as this region server's</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>znode</code> - to check</dd> <dt><span class="strong">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>void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.123">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">Add a peer to hfile reference queue if peer does not exist.</div> +<dl><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> +<a name="addHFileRefs(java.lang.String, java.util.List)"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>addHFileRefs</h4> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.131">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">Add new hfile references to the queue.</div> +<dl><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="blockListLast"> +<li class="blockList"> +<h4>removeHFileRefs</h4> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/replication/ReplicationQueues.html#line.138">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">Remove hfile references from the queue.</div> +<dl><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> </li> </ul> </li>
