@InterfaceAudience.Private public class ReplicationQueueId extends Object
Modifier and Type | Field and Description |
---|---|
private static char |
PEER_ID_SEPARATOR |
private String |
peerId |
private static char |
SERVER_NAME_SEPARATOR |
private ServerName |
serverName |
private Optional<ServerName> |
sourceServerName |
Constructor and Description |
---|
ReplicationQueueId(ServerName serverName,
String peerId) |
ReplicationQueueId(ServerName serverName,
String peerId,
ServerName sourceServerName) |
Modifier and Type | Method and 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(ServerName serverName,
String peerId) |
static byte[] |
getScanPrefix(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() |
private final ServerName serverName
private final Optional<ServerName> sourceServerName
private static final char PEER_ID_SEPARATOR
private static final char SERVER_NAME_SEPARATOR
public ReplicationQueueId(ServerName serverName, String peerId)
public ReplicationQueueId(ServerName serverName, String peerId, ServerName sourceServerName)
public ServerName getServerName()
public Optional<ServerName> getSourceServerName()
public ServerName getServerWALsBelongTo()
public boolean isRecovered()
public ReplicationQueueId claim(ServerName targetServerName)
public static ReplicationQueueId parse(String str)
public static byte[] getScanPrefix(ServerName serverName, String peerId)
public static byte[] getScanPrefix(String peerId)
private static char getNextChar(char c)
public static byte[] getScanStartRowForNextPeerId(String peerId)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.