org.apache.hadoop.hbase.replication.ReplicationQueueId
ReplicationQueueId.claim(org.apache.hadoop.hbase.ServerName targetServerName)
org.apache.hadoop.hbase.replication.ReplicationQueueId
ReplicationQueueData.getId()
org.apache.hadoop.hbase.replication.ReplicationQueueId
ZKReplicationQueueStorageForMigration.ZkReplicationQueueData.getQueueId()
static org.apache.hadoop.hbase.replication.ReplicationQueueId
ReplicationQueueId.parse(String str)
List<org.apache.hadoop.hbase.replication.ReplicationQueueId>
ReplicationQueueStorage.listAllQueueIds(String peerId)
Get a list of all queues for the specific peer.
List<org.apache.hadoop.hbase.replication.ReplicationQueueId>
ReplicationQueueStorage.listAllQueueIds(String peerId,
org.apache.hadoop.hbase.ServerName serverName)
Get a list of all queues for the specific region server and the specific peer
List<org.apache.hadoop.hbase.replication.ReplicationQueueId>
ReplicationQueueStorage.listAllQueueIds(org.apache.hadoop.hbase.ServerName serverName)
Get a list of all queues for the specific region server.
List<org.apache.hadoop.hbase.replication.ReplicationQueueId>
TableReplicationQueueStorage.listAllQueueIds(String peerId)
List<org.apache.hadoop.hbase.replication.ReplicationQueueId>
TableReplicationQueueStorage.listAllQueueIds(String peerId,
org.apache.hadoop.hbase.ServerName serverName)
List<org.apache.hadoop.hbase.replication.ReplicationQueueId>
TableReplicationQueueStorage.listAllQueueIds(org.apache.hadoop.hbase.ServerName serverName)
Map<String,org.apache.hadoop.hbase.replication.ReplicationGroupOffset>
ReplicationQueueStorage.claimQueue(org.apache.hadoop.hbase.replication.ReplicationQueueId queueId,
org.apache.hadoop.hbase.ServerName targetServerName)
Change ownership for the queue identified by queueId and belongs to a dead region server.
Map<String,org.apache.hadoop.hbase.replication.ReplicationGroupOffset>
TableReplicationQueueStorage.claimQueue(org.apache.hadoop.hbase.replication.ReplicationQueueId queueId,
org.apache.hadoop.hbase.ServerName targetServerName)
Map<String,org.apache.hadoop.hbase.replication.ReplicationGroupOffset>
ReplicationQueueStorage.getOffsets(org.apache.hadoop.hbase.replication.ReplicationQueueId queueId)
Get the current offset of all the WAL groups for a queue
Map<String,org.apache.hadoop.hbase.replication.ReplicationGroupOffset>
TableReplicationQueueStorage.getOffsets(org.apache.hadoop.hbase.replication.ReplicationQueueId queueId)
void
ReplicationQueueStorage.removeQueue(org.apache.hadoop.hbase.replication.ReplicationQueueId queueId)
Remove a replication queue
void
TableReplicationQueueStorage.removeQueue(org.apache.hadoop.hbase.replication.ReplicationQueueId queueId)
void
ReplicationQueueStorage.setOffset(org.apache.hadoop.hbase.replication.ReplicationQueueId queueId,
String walGroup,
org.apache.hadoop.hbase.replication.ReplicationGroupOffset offset,
Map<String,Long> lastSeqIds)
Set the current offset for a specific WAL group in a given queue.
void
TableReplicationQueueStorage.setOffset(org.apache.hadoop.hbase.replication.ReplicationQueueId queueId,
String walGroup,
org.apache.hadoop.hbase.replication.ReplicationGroupOffset offset,
Map<String,Long> lastSeqIds)