org.apache.hadoop.hbase.util.hbck

Class ReplicationChecker

java.lang.Object

org.apache.hadoop.hbase.util.hbck.ReplicationChecker

@InterfaceAudience.Private
public class ReplicationChecker
extends Object

Check and fix undeleted replication queues for removed peerId.

Field Summary

Fields

Modifier and Type	Field and Description
private HbckErrorReporter	errorReporter
private static org.slf4j.Logger	LOG
private ReplicationPeerStorage	peerStorage
private ReplicationQueueStorage	queueStorage
private Set<String>	undeletedHFileRefsPeerIds
private Map<ServerName,List<String>>	undeletedQueueIds

Constructor Summary

Constructors

Constructor and Description
ReplicationChecker(org.apache.hadoop.conf.Configuration conf, ZKWatcher zkw, HbckErrorReporter errorReporter)

Method Summary

Modifier and Type	Method and Description
void	checkUnDeletedQueues()
void	fixUnDeletedQueues()
private Set<String>	getUndeletedHFileRefsPeers()
private Map<ServerName,List<String>>	getUnDeletedQueues()
boolean	hasUnDeletedQueues()

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

errorReporter

private final HbckErrorReporter errorReporter

undeletedQueueIds

private Map<ServerName,List<String>> undeletedQueueIds

undeletedHFileRefsPeerIds

private Set<String> undeletedHFileRefsPeerIds

peerStorage

private final ReplicationPeerStorage peerStorage

queueStorage

private final ReplicationQueueStorage queueStorage

Constructor Detail

ReplicationChecker

public ReplicationChecker(org.apache.hadoop.conf.Configuration conf,
                          ZKWatcher zkw,
                          HbckErrorReporter errorReporter)

Method Detail

hasUnDeletedQueues

public boolean hasUnDeletedQueues()

getUnDeletedQueues

private Map<ServerName,List<String>> getUnDeletedQueues()
                                                 throws ReplicationException

Throws:

ReplicationException

getUndeletedHFileRefsPeers

private Set<String> getUndeletedHFileRefsPeers()
                                        throws ReplicationException

Throws:

ReplicationException

checkUnDeletedQueues

public void checkUnDeletedQueues()
                          throws ReplicationException

Throws:

ReplicationException

fixUnDeletedQueues

public void fixUnDeletedQueues()
                        throws ReplicationException

Throws:

ReplicationException