@InterfaceAudience.Private public class ReplicationQueueInfo extends Object
Modifier and Type | Field and Description |
---|---|
private List<ServerName> |
deadRegionServers |
private static org.slf4j.Logger |
LOG |
private String |
peerId |
private String |
queueId |
private boolean |
queueRecovered |
Constructor and Description |
---|
ReplicationQueueInfo(String queueId)
The passed queueId will be either the id of the peer or the handling story of that queue in the
form of id-servername-*
|
Modifier and Type | Method and Description |
---|---|
private static void |
extractDeadServersFromZNodeString(String deadServerListStr,
List<ServerName> result)
Parse dead server names from queue id.
|
List<ServerName> |
getDeadRegionServers() |
String |
getPeerId() |
String |
getQueueId() |
boolean |
isQueueRecovered() |
private static final org.slf4j.Logger LOG
private boolean queueRecovered
private List<ServerName> deadRegionServers
public ReplicationQueueInfo(String queueId)
private static void extractDeadServersFromZNodeString(String deadServerListStr, List<ServerName> result)
public List<ServerName> getDeadRegionServers()
public String getQueueId()
public boolean isQueueRecovered()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.