org.apache.hadoop.hbase.replication

Class ReplicationQueueInfo

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationQueueInfo

@InterfaceAudience.Private
public class ReplicationQueueInfo
extends Object

This class is responsible for the parsing logic for a znode representing a queue. It will extract the peerId if it's recovered as well as the dead region servers that were part of the queue's history.

Field Summary

Fields

Modifier and Type	Field and Description
private List<ServerName>	deadRegionServers
private static org.slf4j.Logger	LOG
private String	peerClusterZnode
private String	peerId
private boolean	queueRecovered

Constructor Summary

Constructors

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-*

Method Summary

Modifier and Type	Method and Description
private static void	extractDeadServersFromZNodeString(String deadServerListStr, List<ServerName> 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-<server name>-...
List<ServerName>	getDeadRegionServers()
String	getPeerClusterZnode()
String	getPeerId()
boolean	isQueueRecovered()

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

peerId

private final String peerId

peerClusterZnode

private final String peerClusterZnode

queueRecovered

private boolean queueRecovered

deadRegionServers

private List<ServerName> deadRegionServers

Constructor Detail

ReplicationQueueInfo

public 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-*

Method Detail

extractDeadServersFromZNodeString

private static void extractDeadServersFromZNodeString(String deadServerListStr,
                                                      List<ServerName> 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-<server name>-...

getDeadRegionServers

public List<ServerName> getDeadRegionServers()

getPeerId

public String getPeerId()

getPeerClusterZnode

public String getPeerClusterZnode()

isQueueRecovered

public boolean isQueueRecovered()