Uses of Class
org.apache.hadoop.hbase.replication.ReplicationGroupOffset
Package
Description
Multi Cluster Replication
-
Uses of ReplicationGroupOffset in org.apache.hadoop.hbase.master.replication
Modifier and TypeFieldDescriptionprivate final Map<ReplicationQueueId,
Map<String, ReplicationGroupOffset>> OfflineTableReplicationQueueStorage.offsets
Modifier and TypeMethodDescriptionOfflineTableReplicationQueueStorage.claimQueue
(ReplicationQueueId queueId, ServerName targetServerName) OfflineTableReplicationQueueStorage.getOffsets
(ReplicationQueueId queueId) Modifier and TypeMethodDescriptionvoid
OfflineTableReplicationQueueStorage.setOffset
(ReplicationQueueId queueId, String walGroup, ReplicationGroupOffset offset, Map<String, Long> lastSeqIds) -
Uses of ReplicationGroupOffset in org.apache.hadoop.hbase.replication
Modifier and TypeFieldDescriptionstatic final ReplicationGroupOffset
ReplicationGroupOffset.BEGIN
Modifier and TypeFieldDescriptionprivate final org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<String,
ReplicationGroupOffset> ReplicationQueueData.offsets
Modifier and TypeMethodDescriptionReplicationQueueStorage.claimQueue
(ReplicationQueueId queueId, ServerName targetServerName) Change ownership for the queue identified by queueId and belongs to a dead region server.TableReplicationQueueStorage.claimQueue
(ReplicationQueueId queueId, ServerName targetServerName) org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<String,
ReplicationGroupOffset> ReplicationQueueData.getOffsets()
ReplicationQueueStorage.getOffsets
(ReplicationQueueId queueId) Get the current offset of all the WAL groups for a queueTableReplicationQueueStorage.getOffsets
(ReplicationQueueId queueId) private Map<String,
ReplicationGroupOffset> TableReplicationQueueStorage.getOffsets0
(Table table, ReplicationQueueId queueId) private org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<String,
ReplicationGroupOffset> TableReplicationQueueStorage.parseOffsets
(Result result) Modifier and TypeMethodDescriptionvoid
ReplicationQueueStorage.setOffset
(ReplicationQueueId queueId, String walGroup, ReplicationGroupOffset offset, Map<String, Long> lastSeqIds) Set the current offset for a specific WAL group in a given queue.void
TableReplicationQueueStorage.setOffset
(ReplicationQueueId queueId, String walGroup, ReplicationGroupOffset offset, Map<String, Long> lastSeqIds) static boolean
ReplicationOffsetUtil.shouldReplicate
(ReplicationGroupOffset offset, String wal) ModifierConstructorDescriptionReplicationQueueData
(ReplicationQueueId id, org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<String, ReplicationGroupOffset> offsets) -
Uses of ReplicationGroupOffset in org.apache.hadoop.hbase.replication.master
Modifier and TypeFieldDescriptionprivate Map<ServerName,
Map<String, Map<String, ReplicationGroupOffset>>> ReplicationLogCleaner.replicationOffsets
Modifier and TypeMethodDescriptionprivate boolean
ReplicationLogCleaner.shouldDelete
(ReplicationGroupOffset offset, org.apache.hadoop.fs.FileStatus file) -
Uses of ReplicationGroupOffset in org.apache.hadoop.hbase.replication.regionserver
Modifier and TypeFieldDescriptionprotected org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<String,
ReplicationGroupOffset> ReplicationSource.startOffsets
Modifier and TypeMethodDescriptionprivate boolean
ReplicationSourceManager.shouldReplicate
(ReplicationGroupOffset offset, String wal) Check whether we should replicate the givenwal
.Modifier and TypeMethodDescriptionprivate String
DumpReplicationQueues.formatQueue
(ServerName regionServer, Map<String, ReplicationGroupOffset> offsets, List<String> wals, ReplicationQueueId queueId, boolean isDeleted, boolean hdfs) private PriorityQueue<org.apache.hadoop.fs.Path>
ReplicationSourceManager.getWALFilesToReplicate
(ServerName sourceRS, boolean syncUp, Map<String, ReplicationGroupOffset> offsets)