org.apache.hadoop.hbase.master.cleaner

Class ReplicationZKNodeCleaner

java.lang.Object

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

@InterfaceAudience.Private
public class ReplicationZKNodeCleaner
extends Object

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	ReplicationZKNodeCleaner.ReplicationQueueDeletor

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
private ReplicationZKNodeCleaner.ReplicationQueueDeletor	queueDeletor
private ReplicationQueuesClient	queuesClient
private ReplicationPeers	replicationPeers
private ZKWatcher	zkw

Constructor Summary

Constructors

Constructor and Description
ReplicationZKNodeCleaner(org.apache.hadoop.conf.Configuration conf, ZKWatcher zkw, Abortable abortable)

Method Summary

Modifier and Type	Method and Description
Set<String>	getUnDeletedHFileRefsQueues()
Map<String,List<String>>	getUnDeletedQueues()
void	removeHFileRefsQueues(Set<String> undeletedHFileRefsQueues) Remove the undeleted hfile-refs queue's zk node for removed peers.
void	removeQueues(Map<String,List<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

Field Detail

LOG

private static final org.slf4j.Logger LOG

zkw

private final ZKWatcher zkw

queuesClient

private final ReplicationQueuesClient queuesClient

replicationPeers

private final ReplicationPeers replicationPeers

queueDeletor

private final ReplicationZKNodeCleaner.ReplicationQueueDeletor queueDeletor

Constructor Detail

ReplicationZKNodeCleaner

public ReplicationZKNodeCleaner(org.apache.hadoop.conf.Configuration conf,
                                ZKWatcher zkw,
                                Abortable abortable)
                         throws IOException

Throws:

IOException

Method Detail

getUnDeletedQueues

public Map<String,List<String>> getUnDeletedQueues()
                                            throws IOException

Returns:

undeletedQueues replicator with its queueIds for removed peers

Throws:

IOException

getUnDeletedHFileRefsQueues

public Set<String> getUnDeletedHFileRefsQueues()
                                        throws IOException

Returns:

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

Throws:

IOException

removeQueues

public void removeQueues(Map<String,List<String>> undeletedQueues)
                  throws IOException

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

Parameters:

undeletedQueues - replicator with its queueIds for removed peers

Throws:

IOException

removeHFileRefsQueues

public void removeHFileRefsQueues(Set<String> undeletedHFileRefsQueues)
                           throws 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:

IOException