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, ourClusterKey, peerStateNodeName, peersZNode, queuesZNode, replicationZNode, zookeeper

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
List<String>	getAllQueues(String serverName) Get a list of all queues for the specified region server.
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.
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