Package org.apache.hadoop.hbase.replication

Class ReplicationQueueId

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationQueueId

@Private
public class ReplicationQueueId
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static final char	PEER_ID_SEPARATOR
private final String	peerId
private static final char	SERVER_NAME_SEPARATOR
private final ServerName	serverName
private final Optional<ServerName>	sourceServerName

Constructor Summary

Constructors

Constructor	Description
ReplicationQueueId(ServerName serverName, String peerId)
ReplicationQueueId(ServerName serverName, String peerId, ServerName sourceServerName)

Method Summary

Modifier and Type	Method	Description
ReplicationQueueId	claim(ServerName targetServerName)
boolean	equals(Object obj)
private static char	getNextChar(char c)
String	getPeerId()
static String	getPeerId(String str)
static byte[]	getScanPrefix(String peerId)
static byte[]	getScanPrefix(ServerName serverName, String peerId)
static byte[]	getScanStartRowForNextPeerId(String peerId)
ServerName	getServerName()
ServerName	getServerWALsBelongTo()
Optional<ServerName>	getSourceServerName()
int	hashCode()
boolean	isRecovered()
static ReplicationQueueId	parse(String str)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

serverName

private final ServerName serverName

peerId

private final String peerId

sourceServerName

private final Optional<ServerName> sourceServerName

PEER_ID_SEPARATOR

private static final char PEER_ID_SEPARATOR

See Also:

• Constant Field Values

SERVER_NAME_SEPARATOR

private static final char SERVER_NAME_SEPARATOR

See Also:

• Constant Field Values

Constructor Details

ReplicationQueueId

public ReplicationQueueId(ServerName serverName,
 String peerId)

ReplicationQueueId

public ReplicationQueueId(ServerName serverName,
 String peerId,
 ServerName sourceServerName)

Method Details

getServerName

public ServerName getServerName()

getPeerId

public String getPeerId()

getSourceServerName

public Optional<ServerName> getSourceServerName()

getServerWALsBelongTo

public ServerName getServerWALsBelongTo()

isRecovered

public boolean isRecovered()

claim

public ReplicationQueueId claim(ServerName targetServerName)

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object

parse

public static ReplicationQueueId parse(String str)

getPeerId

public static String getPeerId(String str)

getScanPrefix

public static byte[] getScanPrefix(ServerName serverName,
 String peerId)

getScanPrefix

public static byte[] getScanPrefix(String peerId)

getNextChar

private static char getNextChar(char c)

getScanStartRowForNextPeerId

public static byte[] getScanStartRowForNextPeerId(String peerId)