@InterfaceAudience.Private public class ReplicationChecker extends Object
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<ReplicationQueueId>> |
undeletedQueueIds |
Constructor and Description |
---|
ReplicationChecker(org.apache.hadoop.conf.Configuration conf,
ZKWatcher zkw,
Connection conn,
HbckErrorReporter errorReporter) |
Modifier and Type | Method and Description |
---|---|
boolean |
checkHasDataInQueues() |
void |
checkUnDeletedQueues() |
void |
fixUnDeletedQueues() |
private Set<String> |
getUndeletedHFileRefsPeers() |
private Map<ServerName,List<ReplicationQueueId>> |
getUnDeletedQueues() |
boolean |
hasUnDeletedQueues() |
private static final org.slf4j.Logger LOG
private final HbckErrorReporter errorReporter
private Map<ServerName,List<ReplicationQueueId>> undeletedQueueIds
private Set<String> undeletedHFileRefsPeerIds
private final ReplicationPeerStorage peerStorage
private final ReplicationQueueStorage queueStorage
public ReplicationChecker(org.apache.hadoop.conf.Configuration conf, ZKWatcher zkw, Connection conn, HbckErrorReporter errorReporter) throws IOException
IOException
public boolean hasUnDeletedQueues()
private Map<ServerName,List<ReplicationQueueId>> getUnDeletedQueues() throws ReplicationException
ReplicationException
private Set<String> getUndeletedHFileRefsPeers() throws ReplicationException
ReplicationException
public void checkUnDeletedQueues() throws ReplicationException
ReplicationException
public void fixUnDeletedQueues() throws ReplicationException
ReplicationException
public boolean checkHasDataInQueues() throws ReplicationException
ReplicationException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.