Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.client.replication | |
org.apache.hadoop.hbase.master | |
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 | |
org.apache.hadoop.hbase.util.hbck |
Modifier and Type | Method and Description |
---|---|
default void |
Admin.appendReplicationPeerTableCFs(String id,
Map<TableName,List<String>> tableCfs)
Append the replicable table column family config from the specified peer.
|
default void |
Admin.removeReplicationPeerTableCFs(String id,
Map<TableName,List<String>> tableCfs)
Remove some table-cfs from config of the specified peer.
|
Modifier and Type | Method and Description |
---|---|
static ReplicationPeerConfig |
ReplicationPeerConfigUtil.appendExcludeTableCFsToReplicationPeerConfig(Map<TableName,List<String>> excludeTableCfs,
ReplicationPeerConfig peerConfig) |
static ReplicationPeerConfig |
ReplicationPeerConfigUtil.removeExcludeTableCFsFromReplicationPeerConfig(Map<TableName,List<String>> excludeTableCfs,
ReplicationPeerConfig peerConfig,
String id) |
static ReplicationPeerConfig |
ReplicationPeerConfigUtil.removeTableCFsFromReplicationPeerConfig(Map<TableName,List<String>> tableCfs,
ReplicationPeerConfig peerConfig,
String id) |
Modifier and Type | Method and Description |
---|---|
long |
HMaster.addReplicationPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled) |
long |
MasterServices.addReplicationPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled)
Add a new replication peer for replicating data to slave cluster
|
long |
HMaster.disableReplicationPeer(String peerId) |
long |
MasterServices.disableReplicationPeer(String peerId)
Stop the replication stream to the specified peer
|
long |
HMaster.enableReplicationPeer(String peerId) |
long |
MasterServices.enableReplicationPeer(String peerId)
Restart the replication stream to the specified peer
|
private void |
HMaster.finishActiveMasterInitialization()
Finish initialization of HMaster after becoming the primary master.
|
ReplicationPeerConfig |
HMaster.getReplicationPeerConfig(String peerId) |
ReplicationPeerConfig |
MasterServices.getReplicationPeerConfig(String peerId)
Returns the configured ReplicationPeerConfig for the specified peer
|
private void |
HMaster.initializeZKBasedSystemTrackers()
Initialize all ZK based system trackers.
|
List<ReplicationPeerDescription> |
HMaster.listReplicationPeers(String regex) |
List<ReplicationPeerDescription> |
MasterServices.listReplicationPeers(String regex)
Return a list of replication peers.
|
long |
HMaster.removeReplicationPeer(String peerId) |
long |
MasterServices.removeReplicationPeer(String peerId)
Removes a peer and stops the replication
|
long |
HMaster.transitReplicationPeerSyncReplicationState(String peerId,
SyncReplicationState state) |
long |
MasterServices.transitReplicationPeerSyncReplicationState(String peerId,
SyncReplicationState clusterState)
Set current cluster state for a synchronous replication peer.
|
long |
HMaster.updateReplicationPeerConfig(String peerId,
ReplicationPeerConfig peerConfig) |
long |
MasterServices.updateReplicationPeerConfig(String peerId,
ReplicationPeerConfig peerConfig)
Update the peerConfig for the specified peer
|
Modifier and Type | Method and Description |
---|---|
void |
OfflineTableReplicationQueueStorage.addHFileRefs(String peerId,
List<Pair<org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> pairs) |
private void |
AssignReplicationQueuesProcedure.addMissingQueues(MasterProcedureEnv env) |
void |
ReplicationPeerManager.addPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled) |
private void |
UpdatePeerConfigProcedure.addToList(List<String> encodedRegionNames,
String encodedRegionName,
ReplicationQueueStorage queueStorage) |
private void |
AbstractPeerProcedure.addToMap(Map<String,Long> lastSeqIds,
String encodedRegionName,
long barrier,
ReplicationQueueStorage queueStorage) |
void |
OfflineTableReplicationQueueStorage.batchUpdateHFileRefs(String peerId,
List<String> hfileRefs) |
void |
OfflineTableReplicationQueueStorage.batchUpdateLastSequenceIds(List<ZKReplicationQueueStorageForMigration.ZkLastPushedSeqId> lastPushedSeqIds) |
void |
OfflineTableReplicationQueueStorage.batchUpdateQueues(ServerName serverName,
List<ReplicationQueueData> datas) |
private void |
ReplicationPeerManager.checkQueuesDeleted(String peerId) |
Map<String,ReplicationGroupOffset> |
OfflineTableReplicationQueueStorage.claimQueue(ReplicationQueueId queueId,
ServerName targetServerName) |
private StateMachineProcedure.Flow |
AssignReplicationQueuesProcedure.claimQueues(MasterProcedureEnv env) |
static ReplicationPeerManager |
ReplicationPeerManager.create(MasterServices services,
String clusterId) |
void |
ReplicationPeerManager.disablePeer(String peerId) |
protected void |
AbstractPeerProcedure.enablePeer(MasterProcedureEnv env) |
void |
ReplicationPeerManager.enablePeer(String peerId) |
Set<String> |
OfflineTableReplicationQueueStorage.getAllHFileRefs() |
List<String> |
OfflineTableReplicationQueueStorage.getAllPeersFromHFileRefsQueue() |
long |
OfflineTableReplicationQueueStorage.getLastSequenceId(String encodedRegionName,
String peerId) |
Map<String,ReplicationGroupOffset> |
OfflineTableReplicationQueueStorage.getOffsets(ReplicationQueueId queueId) |
boolean |
ReplicationPeerManager.getPeerState(String peerId) |
List<String> |
OfflineTableReplicationQueueStorage.getReplicableHFiles(String peerId) |
boolean |
OfflineTableReplicationQueueStorage.hasData() |
List<ReplicationQueueId> |
OfflineTableReplicationQueueStorage.listAllQueueIds(ServerName serverName) |
List<ReplicationQueueId> |
OfflineTableReplicationQueueStorage.listAllQueueIds(String peerId) |
List<ReplicationQueueId> |
OfflineTableReplicationQueueStorage.listAllQueueIds(String peerId,
ServerName serverName) |
List<ReplicationQueueData> |
OfflineTableReplicationQueueStorage.listAllQueues() |
List<ServerName> |
OfflineTableReplicationQueueStorage.listAllReplicators() |
protected void |
RemovePeerProcedure.postPeerModification(MasterProcedureEnv env) |
protected abstract void |
ModifyPeerProcedure.postPeerModification(MasterProcedureEnv env)
Called before we finish the procedure.
|
protected void |
AddPeerProcedure.postPeerModification(MasterProcedureEnv env) |
protected void |
UpdatePeerConfigProcedure.postPeerModification(MasterProcedureEnv env) |
(package private) void |
ReplicationPeerManager.preAddPeer(String peerId,
ReplicationPeerConfig peerConfig) |
protected abstract void |
ModifyPeerProcedure.prePeerModification(MasterProcedureEnv env)
Called before we start the actual processing.
|
protected void |
AddPeerProcedure.prePeerModification(MasterProcedureEnv env) |
(package private) void |
ReplicationPeerManager.removeAllLastPushedSeqIds(String peerId) |
void |
ReplicationPeerManager.removeAllQueues(String peerId) |
void |
OfflineTableReplicationQueueStorage.removeAllQueues(String peerId) |
void |
ReplicationPeerManager.removeAllQueuesAndHFileRefs(String peerId) |
protected void |
TransitPeerSyncReplicationStateProcedure.removeAllReplicationQueues(MasterProcedureEnv env) |
void |
OfflineTableReplicationQueueStorage.removeHFileRefs(String peerId,
List<String> files) |
void |
OfflineTableReplicationQueueStorage.removeLastSequenceIds(String peerId) |
void |
OfflineTableReplicationQueueStorage.removeLastSequenceIds(String peerId,
List<String> encodedRegionNames) |
void |
OfflineTableReplicationQueueStorage.removeLastSequenceIdsAndHFileRefsBefore(long ts) |
void |
ReplicationPeerManager.removePeer(String peerId) |
void |
OfflineTableReplicationQueueStorage.removePeerFromHFileRefs(String peerId) |
void |
OfflineTableReplicationQueueStorage.removeQueue(ReplicationQueueId queueId) |
private void |
AssignReplicationQueuesProcedure.removeQueues(MasterProcedureEnv env) |
protected void |
AbstractPeerProcedure.setLastPushedSequenceId(MasterProcedureEnv env,
ReplicationPeerConfig peerConfig) |
protected void |
AbstractPeerProcedure.setLastPushedSequenceIdForTable(MasterProcedureEnv env,
TableName tableName,
Map<String,Long> lastSeqIds) |
void |
OfflineTableReplicationQueueStorage.setLastSequenceIds(String peerId,
Map<String,Long> lastSeqIds) |
void |
OfflineTableReplicationQueueStorage.setOffset(ReplicationQueueId queueId,
String walGroup,
ReplicationGroupOffset offset,
Map<String,Long> lastSeqIds) |
protected void |
TransitPeerSyncReplicationStateProcedure.setPeerNewSyncReplicationState(MasterProcedureEnv env) |
void |
ReplicationPeerManager.setPeerNewSyncReplicationState(String peerId,
SyncReplicationState state) |
private void |
ReplicationPeerManager.setPeerState(String peerId,
boolean enabled) |
protected void |
TransitPeerSyncReplicationStateProcedure.transitPeerSyncReplicationState(MasterProcedureEnv env) |
void |
ReplicationPeerManager.transitPeerSyncReplicationState(String peerId,
SyncReplicationState newState) |
protected void |
ModifyPeerProcedure.updateLastPushedSequenceIdForSerialPeer(MasterProcedureEnv env) |
protected void |
AddPeerProcedure.updateLastPushedSequenceIdForSerialPeer(MasterProcedureEnv env) |
protected void |
UpdatePeerConfigProcedure.updateLastPushedSequenceIdForSerialPeer(MasterProcedureEnv env) |
void |
ReplicationPeerManager.updatePeerConfig(String peerId,
ReplicationPeerConfig peerConfig) |
protected void |
RemovePeerProcedure.updatePeerStorage(MasterProcedureEnv env) |
protected void |
DisablePeerProcedure.updatePeerStorage(MasterProcedureEnv env) |
protected abstract void |
ModifyPeerProcedure.updatePeerStorage(MasterProcedureEnv env) |
protected void |
AddPeerProcedure.updatePeerStorage(MasterProcedureEnv env) |
protected void |
EnablePeerProcedure.updatePeerStorage(MasterProcedureEnv env) |
protected void |
UpdatePeerConfigProcedure.updatePeerStorage(MasterProcedureEnv env) |
Constructor and Description |
---|
SyncReplicationReplayWALManager(MasterServices services) |
Modifier and Type | Method and Description |
---|---|
void |
TableReplicationQueueStorage.addHFileRefs(String peerId,
List<Pair<org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> pairs) |
void |
ReplicationQueueStorage.addHFileRefs(String peerId,
List<Pair<org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> pairs)
Add new hfile references to the queue.
|
boolean |
ReplicationPeers.addPeer(String peerId)
Method called after a peer has been connected.
|
void |
ReplicationPeerStorage.addPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled,
SyncReplicationState syncReplicationState)
Add a replication peer.
|
void |
ZKReplicationPeerStorage.addPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled,
SyncReplicationState syncReplicationState) |
void |
FSReplicationPeerStorage.addPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled,
SyncReplicationState syncReplicationState) |
void |
TableReplicationQueueStorage.batchUpdateHFileRefs(String peerId,
List<String> hfileRefs) |
void |
ReplicationQueueStorage.batchUpdateHFileRefs(String peerId,
List<String> hfileRefs)
Add the given hfile refs to the given peer.
|
void |
TableReplicationQueueStorage.batchUpdateLastSequenceIds(List<ZKReplicationQueueStorageForMigration.ZkLastPushedSeqId> lastPushedSeqIds) |
void |
ReplicationQueueStorage.batchUpdateLastSequenceIds(List<ZKReplicationQueueStorageForMigration.ZkLastPushedSeqId> lastPushedSeqIds)
Update last pushed sequence id for the given regions and peers.
|
void |
TableReplicationQueueStorage.batchUpdateQueues(ServerName serverName,
List<ReplicationQueueData> datas) |
void |
ReplicationQueueStorage.batchUpdateQueues(ServerName serverName,
List<ReplicationQueueData> datas)
Update the replication queue datas for a given region server.
|
Map<String,ReplicationGroupOffset> |
TableReplicationQueueStorage.claimQueue(ReplicationQueueId queueId,
ServerName targetServerName) |
Map<String,ReplicationGroupOffset> |
ReplicationQueueStorage.claimQueue(ReplicationQueueId queueId,
ServerName targetServerName)
Change ownership for the queue identified by queueId and belongs to a dead region server.
|
private ReplicationPeerImpl |
ReplicationPeers.createPeer(String peerId)
Helper method to connect to a peer
|
Set<String> |
TableReplicationQueueStorage.getAllHFileRefs() |
Set<String> |
ReplicationQueueStorage.getAllHFileRefs()
Load all hfile references in all replication queues.
|
List<String> |
TableReplicationQueueStorage.getAllPeersFromHFileRefsQueue() |
List<String> |
ReplicationQueueStorage.getAllPeersFromHFileRefsQueue()
Get list of all peers from hfile reference queue.
|
long |
TableReplicationQueueStorage.getLastSequenceId(String encodedRegionName,
String peerId) |
long |
ReplicationQueueStorage.getLastSequenceId(String encodedRegionName,
String peerId)
Read the max sequence id of the specific region for a given peer.
|
Map<String,ReplicationGroupOffset> |
TableReplicationQueueStorage.getOffsets(ReplicationQueueId queueId) |
Map<String,ReplicationGroupOffset> |
ReplicationQueueStorage.getOffsets(ReplicationQueueId queueId)
Get the current offset of all the WAL groups for a queue
|
static org.apache.hadoop.conf.Configuration |
ReplicationUtils.getPeerClusterConfiguration(ReplicationPeerConfig peerConfig,
org.apache.hadoop.conf.Configuration baseConf) |
ReplicationPeerConfig |
ReplicationPeerStorage.getPeerConfig(String peerId)
Get the peer config of a replication peer.
|
ReplicationPeerConfig |
ZKReplicationPeerStorage.getPeerConfig(String peerId) |
ReplicationPeerConfig |
FSReplicationPeerStorage.getPeerConfig(String peerId) |
SyncReplicationState |
ReplicationPeerStorage.getPeerNewSyncReplicationState(String peerId)
Get the new sync replication state.
|
SyncReplicationState |
ZKReplicationPeerStorage.getPeerNewSyncReplicationState(String peerId) |
SyncReplicationState |
FSReplicationPeerStorage.getPeerNewSyncReplicationState(String peerId) |
SyncReplicationState |
ReplicationPeerStorage.getPeerSyncReplicationState(String peerId)
Get the sync replication state.
|
SyncReplicationState |
ZKReplicationPeerStorage.getPeerSyncReplicationState(String peerId) |
SyncReplicationState |
FSReplicationPeerStorage.getPeerSyncReplicationState(String peerId) |
List<String> |
TableReplicationQueueStorage.getReplicableHFiles(String peerId) |
List<String> |
ReplicationQueueStorage.getReplicableHFiles(String peerId)
Get a list of all hfile references in the given peer.
|
private SyncReplicationState |
ZKReplicationPeerStorage.getSyncReplicationState(String peerId,
String path) |
boolean |
TableReplicationQueueStorage.hasData() |
boolean |
ReplicationQueueStorage.hasData()
Whether the replication queue table exists.
|
void |
ReplicationPeers.init() |
boolean |
ReplicationPeerStorage.isPeerEnabled(String peerId)
Test whether a replication peer is enabled.
|
boolean |
ZKReplicationPeerStorage.isPeerEnabled(String peerId) |
boolean |
FSReplicationPeerStorage.isPeerEnabled(String peerId) |
List<ReplicationQueueId> |
TableReplicationQueueStorage.listAllQueueIds(ServerName serverName) |
List<ReplicationQueueId> |
ReplicationQueueStorage.listAllQueueIds(ServerName serverName)
Get a list of all queues for the specific region server.
|
List<ReplicationQueueId> |
TableReplicationQueueStorage.listAllQueueIds(String peerId) |
List<ReplicationQueueId> |
ReplicationQueueStorage.listAllQueueIds(String peerId)
Get a list of all queues for the specific peer.
|
List<ReplicationQueueId> |
TableReplicationQueueStorage.listAllQueueIds(String peerId,
ServerName serverName) |
List<ReplicationQueueId> |
ReplicationQueueStorage.listAllQueueIds(String peerId,
ServerName serverName)
Get a list of all queues for the specific region server and the specific peer
|
List<ReplicationQueueData> |
TableReplicationQueueStorage.listAllQueues() |
List<ReplicationQueueData> |
ReplicationQueueStorage.listAllQueues()
Get a list of all queues and the offsets.
|
List<ServerName> |
TableReplicationQueueStorage.listAllReplicators() |
List<ServerName> |
ReplicationQueueStorage.listAllReplicators()
Get a list of all region servers that have outstanding replication queues.
|
List<String> |
ReplicationPeerStorage.listPeerIds()
Return the peer ids of all replication peers.
|
List<String> |
ZKReplicationPeerStorage.listPeerIds() |
List<String> |
FSReplicationPeerStorage.listPeerIds() |
private void |
CopyReplicationPeers.migrate(ReplicationPeerStorage src,
ReplicationPeerStorage dst) |
ReplicationPeerConfig |
ReplicationPeers.refreshPeerConfig(String peerId) |
SyncReplicationState |
ReplicationPeers.refreshPeerNewSyncReplicationState(String peerId) |
ReplicationPeer.PeerState |
ReplicationPeers.refreshPeerState(String peerId) |
void |
TableReplicationQueueStorage.removeAllQueues(String peerId) |
void |
ReplicationQueueStorage.removeAllQueues(String peerId)
Remove all the replication queues for the given peer.
|
void |
TableReplicationQueueStorage.removeHFileRefs(String peerId,
List<String> files) |
void |
ReplicationQueueStorage.removeHFileRefs(String peerId,
List<String> files)
Remove hfile references from the queue.
|
void |
TableReplicationQueueStorage.removeLastSequenceIds(String peerId) |
void |
ReplicationQueueStorage.removeLastSequenceIds(String peerId)
Remove all the max sequence id record for the given peer.
|
void |
TableReplicationQueueStorage.removeLastSequenceIds(String peerId,
List<String> encodedRegionNames) |
void |
ReplicationQueueStorage.removeLastSequenceIds(String peerId,
List<String> encodedRegionNames)
Remove the max sequence id record for the given peer and regions.
|
void |
TableReplicationQueueStorage.removeLastSequenceIdsAndHFileRefsBefore(long ts) |
void |
ReplicationQueueStorage.removeLastSequenceIdsAndHFileRefsBefore(long ts)
Remove all the last sequence ids and hfile references data which are written before the given
timestamp.
|
void |
ReplicationPeerStorage.removePeer(String peerId)
Remove a replication peer.
|
void |
ZKReplicationPeerStorage.removePeer(String peerId) |
void |
FSReplicationPeerStorage.removePeer(String peerId) |
void |
TableReplicationQueueStorage.removePeerFromHFileRefs(String peerId) |
void |
ReplicationQueueStorage.removePeerFromHFileRefs(String peerId)
Remove a peer from hfile reference queue.
|
void |
TableReplicationQueueStorage.removeQueue(ReplicationQueueId queueId) |
void |
ReplicationQueueStorage.removeQueue(ReplicationQueueId queueId)
Remove a replication queue
|
void |
TableReplicationQueueStorage.setLastSequenceIds(String peerId,
Map<String,Long> lastSeqIds) |
void |
ReplicationQueueStorage.setLastSequenceIds(String peerId,
Map<String,Long> lastSeqIds)
Set the max sequence id of a bunch of regions for a given peer.
|
void |
TableReplicationQueueStorage.setOffset(ReplicationQueueId queueId,
String walGroup,
ReplicationGroupOffset offset,
Map<String,Long> lastSeqIds) |
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 |
ReplicationPeerStorage.setPeerNewSyncReplicationState(String peerId,
SyncReplicationState state)
Set the new sync replication state that we are going to transit to.
|
void |
ZKReplicationPeerStorage.setPeerNewSyncReplicationState(String peerId,
SyncReplicationState state) |
void |
FSReplicationPeerStorage.setPeerNewSyncReplicationState(String peerId,
SyncReplicationState newState) |
void |
ReplicationPeerStorage.setPeerState(String peerId,
boolean enabled)
Set the state of peer,
true to ENABLED , otherwise to DISABLED . |
void |
ZKReplicationPeerStorage.setPeerState(String peerId,
boolean enabled) |
void |
FSReplicationPeerStorage.setPeerState(String peerId,
boolean enabled) |
void |
ReplicationPeerStorage.transitPeerSyncReplicationState(String peerId)
Overwrite the sync replication state with the new sync replication state which is set with the
ReplicationPeerStorage.setPeerNewSyncReplicationState(String, SyncReplicationState) method above, and clear
the new sync replication state. |
void |
ZKReplicationPeerStorage.transitPeerSyncReplicationState(String peerId) |
void |
FSReplicationPeerStorage.transitPeerSyncReplicationState(String peerId) |
void |
ReplicationPeerStorage.updatePeerConfig(String peerId,
ReplicationPeerConfig peerConfig)
Update the config a replication peer.
|
void |
ZKReplicationPeerStorage.updatePeerConfig(String peerId,
ReplicationPeerConfig peerConfig) |
void |
FSReplicationPeerStorage.updatePeerConfig(String peerId,
ReplicationPeerConfig peerConfig) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationSourceInterface.addHFileRefs(TableName tableName,
byte[] family,
List<Pair<org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> pairs)
Add hfile names to the queue to be replicated.
|
void |
ReplicationSource.addHFileRefs(TableName tableName,
byte[] family,
List<Pair<org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> pairs) |
private void |
ReplicationSyncUp.addMissingReplicationQueues(ReplicationQueueStorage storage,
ServerName regionServer,
Set<String> peerIds) |
private void |
ReplicationSyncUp.addMissingReplicationQueues(ReplicationQueueStorage storage,
Set<ServerName> regionServers,
Set<String> peerIds) |
void |
PeerProcedureHandler.addPeer(String peerId) |
void |
PeerProcedureHandlerImpl.claimReplicationQueue(ReplicationQueueId queueId) |
void |
PeerProcedureHandler.claimReplicationQueue(ReplicationQueueId queueId) |
private void |
ReplicationSyncUp.claimReplicationQueues(ReplicationSourceManager mgr,
Set<ServerName> regionServers) |
private ReplicationSourceInterface |
ReplicationSourceManager.createRefreshedSource(ReplicationQueueId queueId,
ReplicationPeer peer) |
void |
PeerProcedureHandlerImpl.disablePeer(String peerId) |
void |
PeerProcedureHandler.disablePeer(String peerId) |
void |
ReplicationSourceManager.drainSources(String peerId)
This is used when we transit a sync replication peer to
SyncReplicationState.STANDBY . |
String |
DumpReplicationQueues.dumpReplicationViaTable(Connection connection,
org.apache.hadoop.conf.Configuration conf) |
void |
PeerProcedureHandlerImpl.enablePeer(String peerId) |
void |
PeerProcedureHandler.enablePeer(String peerId) |
void |
ReplicationSourceManager.ReplicationQueueOperation.exec() |
private void |
PeerProcedureHandlerImpl.refreshPeerState(String peerId) |
void |
ReplicationSourceManager.refreshSources(String peerId)
Close the previous replication sources of this peer id and open new sources to trigger the new
replication state changes or new replication config changes.
|
void |
PeerProcedureHandler.removePeer(String peerId) |
void |
PeerProcedureHandlerImpl.transitSyncReplicationPeerState(String peerId,
int stage,
HRegionServer rs) |
void |
PeerProcedureHandler.transitSyncReplicationPeerState(String peerId,
int stage,
HRegionServer rs) |
void |
PeerProcedureHandlerImpl.updatePeerConfig(String peerId) |
void |
PeerProcedureHandler.updatePeerConfig(String peerId) |
Modifier and Type | Method and Description |
---|---|
private void |
HBaseFsck.checkAndFixReplication()
Deprecated.
|
HBaseFsck |
HBaseFsck.exec(ExecutorService exec,
String[] args)
Deprecated.
|
int |
HBaseFsck.onlineHbck()
Deprecated.
Contacts the master and prints out cluster-wide information
|
Modifier and Type | Method and Description |
---|---|
boolean |
ReplicationChecker.checkHasDataInQueues() |
void |
ReplicationChecker.checkUnDeletedQueues() |
void |
ReplicationChecker.fixUnDeletedQueues() |
private Set<String> |
ReplicationChecker.getUndeletedHFileRefsPeers() |
private Map<ServerName,List<ReplicationQueueId>> |
ReplicationChecker.getUnDeletedQueues() |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.