Package | Description |
---|---|
org.apache.hadoop.hbase.master.replication | |
org.apache.hadoop.hbase.replication |
Multi Cluster Replication
|
org.apache.hadoop.hbase.replication.regionserver | |
org.apache.hadoop.hbase.util.hbck |
Modifier and Type | Field and Description |
---|---|
private ReplicationQueueId |
ClaimReplicationQueueRemoteProcedure.queueId |
Modifier and Type | Field and Description |
---|---|
private Map<ReplicationQueueId,Map<String,ReplicationGroupOffset>> |
OfflineTableReplicationQueueStorage.offsets |
Modifier and Type | Method and Description |
---|---|
List<ReplicationQueueId> |
OfflineTableReplicationQueueStorage.listAllQueueIds(ServerName serverName) |
List<ReplicationQueueId> |
OfflineTableReplicationQueueStorage.listAllQueueIds(String peerId) |
List<ReplicationQueueId> |
OfflineTableReplicationQueueStorage.listAllQueueIds(String peerId,
ServerName serverName) |
Modifier and Type | Method and Description |
---|---|
Map<String,ReplicationGroupOffset> |
OfflineTableReplicationQueueStorage.claimQueue(ReplicationQueueId queueId,
ServerName targetServerName) |
Map<String,ReplicationGroupOffset> |
OfflineTableReplicationQueueStorage.getOffsets(ReplicationQueueId queueId) |
void |
OfflineTableReplicationQueueStorage.removeQueue(ReplicationQueueId queueId) |
void |
OfflineTableReplicationQueueStorage.setOffset(ReplicationQueueId queueId,
String walGroup,
ReplicationGroupOffset offset,
Map<String,Long> lastSeqIds) |
Constructor and Description |
---|
ClaimReplicationQueueRemoteProcedure(ReplicationQueueId queueId,
ServerName targetServer) |
Modifier and Type | Field and Description |
---|---|
private ReplicationQueueId |
ReplicationQueueData.id |
private ReplicationQueueId |
ZKReplicationQueueStorageForMigration.ZkReplicationQueueData.queueId |
Modifier and Type | Method and Description |
---|---|
ReplicationQueueId |
ReplicationQueueId.claim(ServerName targetServerName) |
ReplicationQueueId |
ReplicationQueueData.getId() |
ReplicationQueueId |
ZKReplicationQueueStorageForMigration.ZkReplicationQueueData.getQueueId() |
static ReplicationQueueId |
ReplicationQueueId.parse(String str) |
Modifier and Type | Method and Description |
---|---|
List<ReplicationQueueId> |
ReplicationQueueStorage.listAllQueueIds(ServerName serverName)
Get a list of all queues for the specific region server.
|
List<ReplicationQueueId> |
TableReplicationQueueStorage.listAllQueueIds(ServerName serverName) |
List<ReplicationQueueId> |
ReplicationQueueStorage.listAllQueueIds(String peerId)
Get a list of all queues for the specific peer.
|
List<ReplicationQueueId> |
TableReplicationQueueStorage.listAllQueueIds(String peerId) |
List<ReplicationQueueId> |
ReplicationQueueStorage.listAllQueueIds(String peerId,
ServerName serverName)
Get a list of all queues for the specific region server and the specific peer
|
List<ReplicationQueueId> |
TableReplicationQueueStorage.listAllQueueIds(String peerId,
ServerName serverName) |
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) |
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) |
void |
ReplicationQueueStorage.removeQueue(ReplicationQueueId queueId)
Remove a replication queue
|
void |
TableReplicationQueueStorage.removeQueue(ReplicationQueueId queueId) |
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) |
Modifier and Type | Method and Description |
---|---|
private void |
TableReplicationQueueStorage.listAllQueueIds(Table table,
Scan scan,
List<ReplicationQueueId> queueIds) |
private void |
TableReplicationQueueStorage.listAllQueueIds(Table table,
String peerId,
ServerName serverName,
List<ReplicationQueueId> queueIds) |
Constructor and Description |
---|
ReplicationQueueData(ReplicationQueueId id,
org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<String,ReplicationGroupOffset> offsets) |
ZkReplicationQueueData(ReplicationQueueId queueId,
Map<String,Long> walOffsets) |
Modifier and Type | Field and Description |
---|---|
protected ReplicationQueueId |
ReplicationSource.queueId |
private ReplicationQueueId |
ClaimReplicationQueueCallable.queueId |
Modifier and Type | Field and Description |
---|---|
private ConcurrentMap<ReplicationQueueId,Map<String,NavigableSet<String>>> |
ReplicationSourceManager.walsById |
private ConcurrentMap<ReplicationQueueId,Map<String,NavigableSet<org.apache.hadoop.fs.Path>>> |
ReplicationSourceManager.walsByIdRecoveredQueues |
Modifier and Type | Method and Description |
---|---|
ReplicationQueueId |
ReplicationSource.getQueueId() |
ReplicationQueueId |
ReplicationSourceInterface.getQueueId()
Get the queue id that the source is replicating to
|
Modifier and Type | Method and Description |
---|---|
Map<ReplicationQueueId,Map<String,NavigableSet<String>>> |
ReplicationSourceManager.getWALs()
Get a copy of the wals of the normal sources on this rs
|
Modifier and Type | Method and Description |
---|---|
private void |
ReplicationSourceManager.addRecoveredSource(ReplicationSourceInterface src,
ReplicationPeerImpl oldPeer,
ReplicationQueueId claimedQueueId,
PriorityQueue<org.apache.hadoop.fs.Path> walFiles) |
(package private) void |
ReplicationSourceManager.claimQueue(ReplicationQueueId queueId) |
(package private) void |
ReplicationSourceManager.claimQueue(ReplicationQueueId queueId,
boolean syncUp)
Claim a replication queue.
|
void |
PeerProcedureHandler.claimReplicationQueue(ReplicationQueueId queueId) |
void |
PeerProcedureHandlerImpl.claimReplicationQueue(ReplicationQueueId queueId) |
(package private) static ReplicationSourceInterface |
ReplicationSourceFactory.create(org.apache.hadoop.conf.Configuration conf,
ReplicationQueueId queueId) |
private ReplicationSourceInterface |
ReplicationSourceManager.createRefreshedSource(ReplicationQueueId queueId,
ReplicationPeer peer) |
private void |
ReplicationSourceManager.deleteQueue(ReplicationQueueId queueId)
Delete a complete queue of wals associated with a replication source
|
private String |
DumpReplicationQueues.formatQueue(ServerName regionServer,
Map<String,ReplicationGroupOffset> offsets,
List<String> wals,
ReplicationQueueId queueId,
boolean isDeleted,
boolean hdfs) |
Modifier and Type | Field and Description |
---|---|
private Map<ServerName,List<ReplicationQueueId>> |
ReplicationChecker.undeletedQueueIds |
Modifier and Type | Method and Description |
---|---|
private Map<ServerName,List<ReplicationQueueId>> |
ReplicationChecker.getUnDeletedQueues() |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.