org.apache.hadoop.hbase.master.cleaner

Class ReplicationZKNodeCleaner

java.lang.Object

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

public class ReplicationZKNodeCleaner
extends java.lang.Object

Used to clean the replication queues belonging to the peer which does not exist.

Constructor Summary

Constructors

Constructor and Description
ReplicationZKNodeCleaner(Configuration conf, ZKWatcher zkw, Abortable abortable)

Method Summary

Modifier and Type	Method and Description
java.util.Set<java.lang.String>	getUnDeletedHFileRefsQueues()
java.util.Map<java.lang.String,java.util.List<java.lang.String>>	getUnDeletedQueues()
void	removeHFileRefsQueues(java.util.Set<java.lang.String> undeletedHFileRefsQueues) Remove the undeleted hfile-refs queue's zk node for removed peers.
void	removeQueues(java.util.Map<java.lang.String,java.util.List<java.lang.String>> undeletedQueues) Remove the undeleted replication queue's zk node for removed peers.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationZKNodeCleaner

public ReplicationZKNodeCleaner(Configuration conf,
                                ZKWatcher zkw,
                                Abortable abortable)
                         throws java.io.IOException

Throws:

java.io.IOException

Method Detail

getUnDeletedQueues

public java.util.Map<java.lang.String,java.util.List<java.lang.String>> getUnDeletedQueues()
                                                                                    throws java.io.IOException

Returns:

undeletedQueues replicator with its queueIds for removed peers

Throws:

java.io.IOException

getUnDeletedHFileRefsQueues

public java.util.Set<java.lang.String> getUnDeletedHFileRefsQueues()
                                                            throws java.io.IOException

Returns:

undeletedHFileRefsQueue replicator with its undeleted queueIds for removed peers in hfile-refs queue

Throws:

java.io.IOException

removeQueues

public void removeQueues(java.util.Map<java.lang.String,java.util.List<java.lang.String>> undeletedQueues)
                  throws java.io.IOException

Remove the undeleted replication queue's zk node for removed peers.

Parameters:

undeletedQueues - replicator with its queueIds for removed peers

Throws:

java.io.IOException

removeHFileRefsQueues

public void removeHFileRefsQueues(java.util.Set<java.lang.String> undeletedHFileRefsQueues)
                           throws java.io.IOException

Remove the undeleted hfile-refs queue's zk node for removed peers.

Parameters:

undeletedHFileRefsQueues - replicator with its undeleted queueIds for removed peers in hfile-refs queue

Throws:

java.io.IOException