@InterfaceAudience.Private public class ReplicationQueueInfo extends Object
Modifier and Type | Field and Description |
---|---|
private List<String> |
deadRegionServers |
private static org.apache.commons.logging.Log |
LOG |
private String |
peerClusterZnode |
private String |
peerId |
private boolean |
queueRecovered |
Constructor and Description |
---|
ReplicationQueueInfo(String znode)
The passed znode will be either the id of the peer cluster 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<String> result)
Parse dead server names from znode string servername can contain "-" such as
"ip-10-46-221-101.ec2.internal", so we need skip some "-" during parsing for the following
cases: 2-ip-10-46-221-101.ec2.internal,52170,1364333181125-
|
List<String> |
getDeadRegionServers() |
String |
getPeerClusterZnode() |
String |
getPeerId() |
boolean |
isQueueRecovered() |
private static final org.apache.commons.logging.Log LOG
private final String peerId
private final String peerClusterZnode
private boolean queueRecovered
public ReplicationQueueInfo(String znode)
private static void extractDeadServersFromZNodeString(String deadServerListStr, List<String> result)
public String getPeerId()
public String getPeerClusterZnode()
public boolean isQueueRecovered()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.