Package org.apache.hadoop.hbase.replication

Class ReplicationQueueInfo

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationQueueInfo

@Private
public class ReplicationQueueInfo
extends Object

This class is responsible for the parsing logic for a queue id 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	Description
private List<ServerName>	deadRegionServers
private static final org.slf4j.Logger	LOG
private final String	peerId
private final String	queueId
private boolean	queueRecovered

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

peerId

private final String peerId

queueId

private final String queueId

queueRecovered

private boolean queueRecovered

deadRegionServers

private List<ServerName> deadRegionServers

Constructor Details

ReplicationQueueInfo

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

Method Details

extractDeadServersFromZNodeString

private static void extractDeadServersFromZNodeString(String deadServerListStr,
 List<ServerName> result)

Parse dead server names from queue id. 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()

getQueueId

public String getQueueId()

isQueueRecovered

public boolean isQueueRecovered()