Package org.apache.hadoop.hbase.util.hbck

Class ReplicationChecker

java.lang.Object

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

@Private
public class ReplicationChecker
extends Object

Check and fix undeleted replication queues for removed peerId.

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

errorReporter

private final HbckErrorReporter errorReporter

undeletedQueueIds

private Map<ServerName,List<ReplicationQueueId>> undeletedQueueIds

undeletedHFileRefsPeerIds

private Set<String> undeletedHFileRefsPeerIds

peerStorage

private final ReplicationPeerStorage peerStorage

queueStorage

private final ReplicationQueueStorage queueStorage

Constructor Details

ReplicationChecker

public ReplicationChecker(org.apache.hadoop.conf.Configuration conf,
 ZKWatcher zkw,
 Connection conn,
 HbckErrorReporter errorReporter)
                   throws IOException

Throws:

IOException

Method Details

hasUnDeletedQueues

public boolean hasUnDeletedQueues()

getUnDeletedQueues

private Map<ServerName,List<ReplicationQueueId>> 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

checkHasDataInQueues

public boolean checkHasDataInQueues()
                             throws ReplicationException

Throws:

ReplicationException