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

Modifier and Type	Field and Description
(package private) org.slf4j.Logger	LOG

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

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

Constructor Summary

Constructors

Constructor and Description
ReplicationQueuesClientZKImpl(ReplicationQueuesClientArguments args)
ReplicationQueuesClientZKImpl(ZKWatcher zk, org.apache.hadoop.conf.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.
Set<String>	getAllWALs() Load all wals in all replication queues from ZK.
int	getHFileRefsNodeChangeVersion() Get the change version number of replication hfile references node.
List<String>	getListOfReplicators() Get a list of all region servers that have outstanding replication queues.
List<String>	getLogsInQueue(String serverName, String queueId) Get a list of all WALs in the given queue on the given region server.
int	getQueuesZNodeCversion()
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

getListOfReplicatorsZK, getPeerNode, getPeerStateNode, getTableCFsNode, isPeerPath, peerExists, toByteArray

Methods inherited from class java.lang.Object

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

Field Detail

LOG

org.slf4j.Logger LOG

Constructor Detail

ReplicationQueuesClientZKImpl

public ReplicationQueuesClientZKImpl(ReplicationQueuesClientArguments args)

ReplicationQueuesClientZKImpl

public ReplicationQueuesClientZKImpl(ZKWatcher zk,
                                     org.apache.hadoop.conf.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

getListOfReplicators

public List<String> getListOfReplicators()
                                  throws org.apache.zookeeper.KeeperException

Description copied from interface: ReplicationQueuesClient

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.

Specified by:

getListOfReplicators in interface ReplicationQueuesClient

Returns:

a list of server names

Throws:

org.apache.zookeeper.KeeperException - zookeeper exception

getLogsInQueue

public List<String> getLogsInQueue(String serverName,
                                   String queueId)
                            throws org.apache.zookeeper.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:

org.apache.zookeeper.KeeperException - zookeeper exception

getAllQueues

public List<String> getAllQueues(String serverName)
                          throws org.apache.zookeeper.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:

org.apache.zookeeper.KeeperException

getAllWALs

public Set<String> getAllWALs()
                       throws org.apache.zookeeper.KeeperException

Description copied from interface: ReplicationQueuesClient

Load all wals in all replication queues from ZK. This method guarantees to return a snapshot which contains all WALs in the zookeeper at the start of this call even there is concurrent queue failover. However, some newly created WALs during the call may not be included.

Specified by:

getAllWALs in interface ReplicationQueuesClient

Throws:

org.apache.zookeeper.KeeperException

getQueuesZNodeCversion

public int getQueuesZNodeCversion()
                           throws org.apache.zookeeper.KeeperException

Throws:

org.apache.zookeeper.KeeperException

getHFileRefsNodeChangeVersion

public int getHFileRefsNodeChangeVersion()
                                  throws org.apache.zookeeper.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:

org.apache.zookeeper.KeeperException

getAllPeersFromHFileRefsQueue

public List<String> getAllPeersFromHFileRefsQueue()
                                           throws org.apache.zookeeper.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:

org.apache.zookeeper.KeeperException - zookeeper exception

getReplicableHFiles

public List<String> getReplicableHFiles(String peerId)
                                 throws org.apache.zookeeper.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:

org.apache.zookeeper.KeeperException - zookeeper exception