Packages that use org.apache.hadoop.hbase.replication.ReplicationGroupOffset
Multi Cluster Replication
-
static final org.apache.hadoop.hbase.replication.ReplicationGroupOffset
ReplicationGroupOffset.BEGIN
static org.apache.hadoop.hbase.replication.ReplicationGroupOffset
ReplicationGroupOffset.parse(String str)
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)
org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<String,org.apache.hadoop.hbase.replication.ReplicationGroupOffset>
ReplicationQueueData.getOffsets()
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.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)
static boolean
ReplicationOffsetUtil.shouldReplicate(org.apache.hadoop.hbase.replication.ReplicationGroupOffset offset,
String wal)
ReplicationQueueData(org.apache.hadoop.hbase.replication.ReplicationQueueId id,
org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<String,org.apache.hadoop.hbase.replication.ReplicationGroupOffset> offsets)