org.apache.hadoop.hbase.replication

Class ReplicationQueuesClientZKImpl

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationStateZKBase

org.apache.hadoop.hbase.replication.ReplicationQueuesClientZKImpl

All Implemented Interfaces:

ReplicationQueuesClient

@InterfaceAudience.Private
public class ReplicationQueuesClientZKImpl
extends ReplicationStateZKBase
implements ReplicationQueuesClient

Field Summary

Fields inherited from class org.apache.hadoop.hbase.replication.ReplicationStateZKBase

abortable, conf, DISABLED_ZNODE_BYTES, ENABLED_ZNODE_BYTES, hfileRefsZNode, ourClusterKey, peerStateNodeName, peersZNode, queuesZNode, replicationForBulkLoadEnabled, replicationZNode, zookeeper, ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT, ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY

Constructor Summary

Constructors

Constructor and Description
ReplicationQueuesClientZKImpl(ZooKeeperWatcher zk, Configuration conf, Abortable abortable)

Method Summary

Modifier and Type	Method and Description
List<String>	getAllPeersFromHFileRefsQueue() Get list of all peers from hfile reference queue.
List<String>	getAllQueues(String serverName) Get a list of all queues for the specified region server.
int	getHFileRefsNodeChangeVersion() Get the change version number of replication hfile references node.
List<String>	getLogsInQueue(String serverName, String queueId) Get a list of all WALs in the given queue on the given region server.
int	getQueuesZNodeCversion() Get the cversion of replication rs node.
List<String>	getReplicableHFiles(String peerId) Get a list of all hfile references in the given peer.
void	init() Initialize the replication queue client interface.

Methods inherited from class org.apache.hadoop.hbase.replication.ReplicationStateZKBase

getListOfReplicators, isPeerPath, peerExists, toByteArray

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.replication.ReplicationQueuesClient

getListOfReplicators

Constructor Detail

ReplicationQueuesClientZKImpl

public ReplicationQueuesClientZKImpl(ZooKeeperWatcher zk,
                                     Configuration conf,
                                     Abortable abortable)

Method Detail

init

public void init()
          throws ReplicationException

Description copied from interface: ReplicationQueuesClient

Initialize the replication queue client interface.

Specified by:

init in interface ReplicationQueuesClient

Throws:

ReplicationException

getLogsInQueue

public List<String> getLogsInQueue(String serverName,
                                   String queueId)
                            throws KeeperException

Description copied from interface: ReplicationQueuesClient

Get a list of all WALs in the given queue on the given region server.

Specified by:

getLogsInQueue in interface ReplicationQueuesClient

Parameters:

serverName - the server name of the region server that owns the queue

queueId - a String that identifies the queue

Returns:

a list of WALs, null if this region server is dead and has no outstanding queues

Throws:

KeeperException - zookeeper exception

getAllQueues

public List<String> getAllQueues(String serverName)
                          throws KeeperException

Description copied from interface: ReplicationQueuesClient

Get a list of all queues for the specified region server.

Specified by:

getAllQueues in interface ReplicationQueuesClient

Parameters:

serverName - the server name of the region server that owns the set of queues

Returns:

a list of queueIds, null if this region server is not a replicator.

Throws:

KeeperException

getQueuesZNodeCversion

public int getQueuesZNodeCversion()
                           throws KeeperException

Description copied from interface: ReplicationQueuesClient

Get the cversion of replication rs node. This can be used as optimistic locking to get a consistent snapshot of the replication queues.

Specified by:

getQueuesZNodeCversion in interface ReplicationQueuesClient

Returns:

cversion of replication rs node

Throws:

KeeperException

getHFileRefsNodeChangeVersion

public int getHFileRefsNodeChangeVersion()
                                  throws KeeperException

Description copied from interface: ReplicationQueuesClient

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.

Specified by:

getHFileRefsNodeChangeVersion in interface ReplicationQueuesClient

Returns:

change version number of hfile references node

Throws:

KeeperException

getAllPeersFromHFileRefsQueue

public List<String> getAllPeersFromHFileRefsQueue()
                                           throws KeeperException

Description copied from interface: ReplicationQueuesClient

Get list of all peers from hfile reference queue.

Specified by:

getAllPeersFromHFileRefsQueue in interface ReplicationQueuesClient

Returns:

a list of peer ids

Throws:

KeeperException - zookeeper exception

getReplicableHFiles

public List<String> getReplicableHFiles(String peerId)
                                 throws KeeperException

Description copied from interface: ReplicationQueuesClient

Get a list of all hfile references in the given peer.

Specified by:

getReplicableHFiles in interface ReplicationQueuesClient

Parameters:

peerId - a String that identifies the peer

Returns:

a list of hfile references, null if not found any

Throws:

KeeperException - zookeeper exception