org.apache.hadoop.hbase.master.cleaner

Class ReplicationZKNodeCleaner.ReplicationQueueDeletor

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationStateZKBase

org.apache.hadoop.hbase.master.cleaner.ReplicationZKNodeCleaner.ReplicationQueueDeletor

Enclosing class:

ReplicationZKNodeCleaner

private class ReplicationZKNodeCleaner.ReplicationQueueDeletor
extends ReplicationStateZKBase

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, replicationZNode, tableCFsNodeName, zookeeper, ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT, ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY

Constructor Summary

Constructors

Constructor and Description
ReplicationQueueDeletor(ZKWatcher zk, org.apache.hadoop.conf.Configuration conf, Abortable abortable)

Method Summary

Modifier and Type	Method and Description
(package private) String	getHfileRefsZNode()
void	removeHFileRefsQueue(String hfileRefsQueueId)
void	removeQueue(String replicator, String queueId)

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

Constructor Detail

ReplicationQueueDeletor

public ReplicationQueueDeletor(ZKWatcher zk,
                               org.apache.hadoop.conf.Configuration conf,
                               Abortable abortable)

Method Detail

removeQueue

public void removeQueue(String replicator,
                        String queueId)
                 throws IOException

Parameters:

replicator - The regionserver which has undeleted queue

queueId - The undeleted queue id

Throws:

IOException

removeHFileRefsQueue

public void removeHFileRefsQueue(String hfileRefsQueueId)
                          throws IOException

Parameters:

hfileRefsQueueId - The undeleted hfile-refs queue id

Throws:

IOException

getHfileRefsZNode

String getHfileRefsZNode()