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

Field Summary

Fields

Modifier and Type	Field and Description
private ReplicationZKNodeCleaner	cleaner
private HbckErrorReporter	errorReporter
private static org.slf4j.Logger	LOG
private Set<String>	undeletedHFileRefsQueueIds
private Map<String,List<String>>	undeletedQueueIds

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
private void	checkUnDeletedHFileRefsQueues()
void	checkUnDeletedQueues()
private void	fixUnDeletedHFileRefsQueue()
void	fixUnDeletedQueues()
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<String,List<String>> undeletedQueueIds

undeletedHFileRefsQueueIds

private Set<String> undeletedHFileRefsQueueIds

cleaner

private final ReplicationZKNodeCleaner cleaner

Constructor Detail

ReplicationChecker

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

Throws:

IOException

Method Detail

hasUnDeletedQueues

public boolean hasUnDeletedQueues()

checkUnDeletedQueues

public void checkUnDeletedQueues()
                          throws IOException

Throws:

IOException

checkUnDeletedHFileRefsQueues

private void checkUnDeletedHFileRefsQueues()
                                    throws IOException

Throws:

IOException

fixUnDeletedQueues

public void fixUnDeletedQueues()
                        throws IOException

Throws:

IOException

fixUnDeletedHFileRefsQueue

private void fixUnDeletedHFileRefsQueue()
                                 throws IOException

Throws:

IOException