@InterfaceAudience.Private public class ReplicationQueuesClientZKImpl extends ReplicationStateZKBase implements ReplicationQueuesClient
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 and Description |
---|
ReplicationQueuesClientZKImpl(ZooKeeperWatcher zk,
Configuration conf,
Abortable abortable) |
Modifier and Type | Method and Description |
---|---|
java.util.List<java.lang.String> |
getAllPeersFromHFileRefsQueue()
Get list of all peers from hfile reference queue.
|
java.util.List<java.lang.String> |
getAllQueues(java.lang.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.
|
java.util.List<java.lang.String> |
getLogsInQueue(java.lang.String serverName,
java.lang.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.
|
java.util.List<java.lang.String> |
getReplicableHFiles(java.lang.String peerId)
Get a list of all hfile references in the given peer.
|
void |
init()
Initialize the replication queue client interface.
|
getListOfReplicators, isPeerPath, peerExists, toByteArray
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getListOfReplicators
public ReplicationQueuesClientZKImpl(ZooKeeperWatcher zk, Configuration conf, Abortable abortable)
public void init() throws ReplicationException
ReplicationQueuesClient
init
in interface ReplicationQueuesClient
ReplicationException
public java.util.List<java.lang.String> getLogsInQueue(java.lang.String serverName, java.lang.String queueId) throws KeeperException
ReplicationQueuesClient
getLogsInQueue
in interface ReplicationQueuesClient
serverName
- the server name of the region server that owns the queuequeueId
- a String that identifies the queueKeeperException
- zookeeper exceptionpublic java.util.List<java.lang.String> getAllQueues(java.lang.String serverName) throws KeeperException
ReplicationQueuesClient
getAllQueues
in interface ReplicationQueuesClient
serverName
- the server name of the region server that owns the set of queuesKeeperException
public int getQueuesZNodeCversion() throws KeeperException
ReplicationQueuesClient
getQueuesZNodeCversion
in interface ReplicationQueuesClient
KeeperException
public int getHFileRefsNodeChangeVersion() throws KeeperException
ReplicationQueuesClient
getHFileRefsNodeChangeVersion
in interface ReplicationQueuesClient
KeeperException
public java.util.List<java.lang.String> getAllPeersFromHFileRefsQueue() throws KeeperException
ReplicationQueuesClient
getAllPeersFromHFileRefsQueue
in interface ReplicationQueuesClient
KeeperException
- zookeeper exceptionpublic java.util.List<java.lang.String> getReplicableHFiles(java.lang.String peerId) throws KeeperException
ReplicationQueuesClient
getReplicableHFiles
in interface ReplicationQueuesClient
peerId
- a String that identifies the peerKeeperException
- zookeeper exception