public class ReplicationZKNodeCleaner
extends java.lang.Object
Constructor and Description |
---|
ReplicationZKNodeCleaner(Configuration conf,
ZKWatcher zkw,
Abortable abortable) |
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.
|
public ReplicationZKNodeCleaner(Configuration conf, ZKWatcher zkw, Abortable abortable) throws java.io.IOException
java.io.IOException
public java.util.Map<java.lang.String,java.util.List<java.lang.String>> getUnDeletedQueues() throws java.io.IOException
java.io.IOException
public java.util.Set<java.lang.String> getUnDeletedHFileRefsQueues() throws java.io.IOException
java.io.IOException
public void removeQueues(java.util.Map<java.lang.String,java.util.List<java.lang.String>> undeletedQueues) throws java.io.IOException
undeletedQueues
- replicator with its queueIds for removed peersjava.io.IOException
public void removeHFileRefsQueues(java.util.Set<java.lang.String> undeletedHFileRefsQueues) throws java.io.IOException
undeletedHFileRefsQueues
- replicator with its undeleted queueIds for removed peers in
hfile-refs queuejava.io.IOException