Package | Description |
---|---|
org.apache.hadoop.hbase.master.replication | |
org.apache.hadoop.hbase.replication |
Multi Cluster Replication
|
org.apache.hadoop.hbase.replication.master | |
org.apache.hadoop.hbase.replication.regionserver |
Modifier and Type | Field and Description |
---|---|
private Map<ReplicationQueueId,Map<String,ReplicationGroupOffset>> |
OfflineTableReplicationQueueStorage.offsets |
Modifier and Type | Method and Description |
---|---|
Map<String,ReplicationGroupOffset> |
OfflineTableReplicationQueueStorage.claimQueue(ReplicationQueueId queueId,
ServerName targetServerName) |
Map<String,ReplicationGroupOffset> |
OfflineTableReplicationQueueStorage.getOffsets(ReplicationQueueId queueId) |
Modifier and Type | Method and Description |
---|---|
void |
OfflineTableReplicationQueueStorage.setOffset(ReplicationQueueId queueId,
String walGroup,
ReplicationGroupOffset offset,
Map<String,Long> lastSeqIds) |
Modifier and Type | Field and Description |
---|---|
static ReplicationGroupOffset |
ReplicationGroupOffset.BEGIN |
Modifier and Type | Field and Description |
---|---|
private org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<String,ReplicationGroupOffset> |
ReplicationQueueData.offsets |
Modifier and Type | Method and Description |
---|---|
static ReplicationGroupOffset |
ReplicationGroupOffset.parse(String str) |
Modifier and Type | Method and Description |
---|---|
Map<String,ReplicationGroupOffset> |
ReplicationQueueStorage.claimQueue(ReplicationQueueId queueId,
ServerName targetServerName)
Change ownership for the queue identified by queueId and belongs to a dead region server.
|
Map<String,ReplicationGroupOffset> |
TableReplicationQueueStorage.claimQueue(ReplicationQueueId queueId,
ServerName targetServerName) |
org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<String,ReplicationGroupOffset> |
ReplicationQueueData.getOffsets() |
Map<String,ReplicationGroupOffset> |
ReplicationQueueStorage.getOffsets(ReplicationQueueId queueId)
Get the current offset of all the WAL groups for a queue
|
Map<String,ReplicationGroupOffset> |
TableReplicationQueueStorage.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 Type | Method and Description |
---|---|
void |
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) |
Constructor and Description |
---|
ReplicationQueueData(ReplicationQueueId id,
org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<String,ReplicationGroupOffset> offsets) |
Modifier and Type | Field and Description |
---|---|
private Map<ServerName,Map<String,Map<String,ReplicationGroupOffset>>> |
ReplicationLogCleaner.replicationOffsets |
Modifier and Type | Method and Description |
---|---|
private boolean |
ReplicationLogCleaner.shouldDelete(ReplicationGroupOffset offset,
org.apache.hadoop.fs.FileStatus file) |
Modifier and Type | Field and Description |
---|---|
protected org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<String,ReplicationGroupOffset> |
ReplicationSource.startOffsets |
Modifier and Type | Method and Description |
---|---|
private boolean |
ReplicationSourceManager.shouldReplicate(ReplicationGroupOffset offset,
String wal)
Check whether we should replicate the given
wal . |
Modifier and Type | Method and Description |
---|---|
private 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) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.