Uses of Class
org.apache.hadoop.hbase.replication.ReplicationException

Packages that use ReplicationException

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

Uses of ReplicationException in org.apache.hadoop.hbase.client

Methods in org.apache.hadoop.hbase.client that throw ReplicationException

Modifier and Type	Method	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.

Uses of ReplicationException in org.apache.hadoop.hbase.client.replication

Methods in org.apache.hadoop.hbase.client.replication that throw ReplicationException

Modifier and Type	Method	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)

Uses of ReplicationException in org.apache.hadoop.hbase.master

Methods in org.apache.hadoop.hbase.master that throw ReplicationException

Modifier and Type	Method	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

Uses of ReplicationException in org.apache.hadoop.hbase.master.replication

Methods in org.apache.hadoop.hbase.master.replication that throw ReplicationException

Modifier and Type	Method	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(String peerId)
List<ReplicationQueueId>	OfflineTableReplicationQueueStorage.listAllQueueIds(String peerId, ServerName serverName)
List<ReplicationQueueId>	OfflineTableReplicationQueueStorage.listAllQueueIds(ServerName serverName)
List<ReplicationQueueData>	OfflineTableReplicationQueueStorage.listAllQueues()
List<ServerName>	OfflineTableReplicationQueueStorage.listAllReplicators()
protected void	AddPeerProcedure.postPeerModification(MasterProcedureEnv env)
protected abstract void	ModifyPeerProcedure.postPeerModification(MasterProcedureEnv env)	Called before we finish the procedure.
protected void	RemovePeerProcedure.postPeerModification(MasterProcedureEnv env)
protected void	UpdatePeerConfigProcedure.postPeerModification(MasterProcedureEnv env)
(package private) void	ReplicationPeerManager.preAddPeer(String peerId, ReplicationPeerConfig peerConfig)
protected void	AddPeerProcedure.prePeerModification(MasterProcedureEnv env)
protected abstract void	ModifyPeerProcedure.prePeerModification(MasterProcedureEnv env)	Called before we start the actual processing.
(package private) void	ReplicationPeerManager.removeAllLastPushedSeqIds(String peerId)
void	OfflineTableReplicationQueueStorage.removeAllQueues(String peerId)
void	ReplicationPeerManager.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 final void	AbstractPeerProcedure.setLastPushedSequenceId(MasterProcedureEnv env, ReplicationPeerConfig peerConfig)
protected final 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)
void	ReplicationPeerManager.setPeerNewSyncReplicationState(String peerId, SyncReplicationState state)
protected void	TransitPeerSyncReplicationStateProcedure.setPeerNewSyncReplicationState(MasterProcedureEnv env)
private void	ReplicationPeerManager.setPeerState(String peerId, boolean enabled)
void	ReplicationPeerManager.transitPeerSyncReplicationState(String peerId, SyncReplicationState newState)
protected void	TransitPeerSyncReplicationStateProcedure.transitPeerSyncReplicationState(MasterProcedureEnv env)
protected void	AddPeerProcedure.updateLastPushedSequenceIdForSerialPeer(MasterProcedureEnv env)
protected void	ModifyPeerProcedure.updateLastPushedSequenceIdForSerialPeer(MasterProcedureEnv env)
protected void	UpdatePeerConfigProcedure.updateLastPushedSequenceIdForSerialPeer(MasterProcedureEnv env)
void	ReplicationPeerManager.updatePeerConfig(String peerId, ReplicationPeerConfig peerConfig)
protected void	AddPeerProcedure.updatePeerStorage(MasterProcedureEnv env)
protected void	DisablePeerProcedure.updatePeerStorage(MasterProcedureEnv env)
protected void	EnablePeerProcedure.updatePeerStorage(MasterProcedureEnv env)
protected abstract void	ModifyPeerProcedure.updatePeerStorage(MasterProcedureEnv env)
protected void	RemovePeerProcedure.updatePeerStorage(MasterProcedureEnv env)
protected void	UpdatePeerConfigProcedure.updatePeerStorage(MasterProcedureEnv env)

Constructors in org.apache.hadoop.hbase.master.replication that throw ReplicationException

Modifier	Constructor	Description
	SyncReplicationReplayWALManager(MasterServices services)

Uses of ReplicationException in org.apache.hadoop.hbase.replication

Methods in org.apache.hadoop.hbase.replication that throw ReplicationException

Modifier and Type	Method	Description
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.
void	TableReplicationQueueStorage.addHFileRefs(String peerId, List<Pair<org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> pairs)
void	FSReplicationPeerStorage.addPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled, SyncReplicationState syncReplicationState)
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	ReplicationQueueStorage.batchUpdateHFileRefs(String peerId, List<String> hfileRefs)	Add the given hfile refs to the given peer.
void	TableReplicationQueueStorage.batchUpdateHFileRefs(String peerId, List<String> hfileRefs)
void	ReplicationQueueStorage.batchUpdateLastSequenceIds(List<ZKReplicationQueueStorageForMigration.ZkLastPushedSeqId> lastPushedSeqIds)	Update last pushed sequence id for the given regions and peers.
void	TableReplicationQueueStorage.batchUpdateLastSequenceIds(List<ZKReplicationQueueStorageForMigration.ZkLastPushedSeqId> lastPushedSeqIds)
void	ReplicationQueueStorage.batchUpdateQueues(ServerName serverName, List<ReplicationQueueData> datas)	Update the replication queue datas for a given region server.
void	TableReplicationQueueStorage.batchUpdateQueues(ServerName serverName, List<ReplicationQueueData> datas)
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)
private ReplicationPeerImpl	ReplicationPeers.createPeer(String peerId)	Helper method to connect to a peer
Set<String>	ReplicationQueueStorage.getAllHFileRefs()	Load all hfile references in all replication queues.
Set<String>	TableReplicationQueueStorage.getAllHFileRefs()
List<String>	ReplicationQueueStorage.getAllPeersFromHFileRefsQueue()	Get list of all peers from hfile reference queue.
List<String>	TableReplicationQueueStorage.getAllPeersFromHFileRefsQueue()
long	ReplicationQueueStorage.getLastSequenceId(String encodedRegionName, String peerId)	Read the max sequence id of the specific region for a given peer.
long	TableReplicationQueueStorage.getLastSequenceId(String encodedRegionName, String peerId)
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)
ReplicationPeerConfig	FSReplicationPeerStorage.getPeerConfig(String peerId)
ReplicationPeerConfig	ReplicationPeerStorage.getPeerConfig(String peerId)	Get the peer config of a replication peer.
ReplicationPeerConfig	ZKReplicationPeerStorage.getPeerConfig(String peerId)
SyncReplicationState	FSReplicationPeerStorage.getPeerNewSyncReplicationState(String peerId)
SyncReplicationState	ReplicationPeerStorage.getPeerNewSyncReplicationState(String peerId)	Get the new sync replication state.
SyncReplicationState	ZKReplicationPeerStorage.getPeerNewSyncReplicationState(String peerId)
SyncReplicationState	FSReplicationPeerStorage.getPeerSyncReplicationState(String peerId)
SyncReplicationState	ReplicationPeerStorage.getPeerSyncReplicationState(String peerId)	Get the sync replication state.
SyncReplicationState	ZKReplicationPeerStorage.getPeerSyncReplicationState(String peerId)
List<String>	ReplicationQueueStorage.getReplicableHFiles(String peerId)	Get a list of all hfile references in the given peer.
List<String>	TableReplicationQueueStorage.getReplicableHFiles(String peerId)
private SyncReplicationState	ZKReplicationPeerStorage.getSyncReplicationState(String peerId, String path)
boolean	ReplicationQueueStorage.hasData()	Whether the replication queue table exists.
boolean	TableReplicationQueueStorage.hasData()
void	ReplicationPeers.init()
boolean	FSReplicationPeerStorage.isPeerEnabled(String peerId)
boolean	ReplicationPeerStorage.isPeerEnabled(String peerId)	Test whether a replication peer is enabled.
boolean	ZKReplicationPeerStorage.isPeerEnabled(String peerId)
List<ReplicationQueueId>	ReplicationQueueStorage.listAllQueueIds(String peerId)	Get a list of all queues for the specific peer.
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>	ReplicationQueueStorage.listAllQueueIds(ServerName serverName)	Get a list of all queues for the specific region server.
List<ReplicationQueueId>	TableReplicationQueueStorage.listAllQueueIds(String peerId)
List<ReplicationQueueId>	TableReplicationQueueStorage.listAllQueueIds(String peerId, ServerName serverName)
List<ReplicationQueueId>	TableReplicationQueueStorage.listAllQueueIds(ServerName serverName)
List<ReplicationQueueData>	ReplicationQueueStorage.listAllQueues()	Get a list of all queues and the offsets.
List<ReplicationQueueData>	TableReplicationQueueStorage.listAllQueues()
List<ServerName>	ReplicationQueueStorage.listAllReplicators()	Get a list of all region servers that have outstanding replication queues.
List<ServerName>	TableReplicationQueueStorage.listAllReplicators()
List<String>	FSReplicationPeerStorage.listPeerIds()
List<String>	ReplicationPeerStorage.listPeerIds()	Return the peer ids of all replication peers.
List<String>	ZKReplicationPeerStorage.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	ReplicationQueueStorage.removeAllQueues(String peerId)	Remove all the replication queues for the given peer.
void	TableReplicationQueueStorage.removeAllQueues(String peerId)
void	ReplicationQueueStorage.removeHFileRefs(String peerId, List<String> files)	Remove hfile references from the queue.
void	TableReplicationQueueStorage.removeHFileRefs(String peerId, List<String> files)
void	ReplicationQueueStorage.removeLastSequenceIds(String peerId)	Remove all the max sequence id record for the given peer.
void	ReplicationQueueStorage.removeLastSequenceIds(String peerId, List<String> encodedRegionNames)	Remove the max sequence id record for the given peer and regions.
void	TableReplicationQueueStorage.removeLastSequenceIds(String peerId)
void	TableReplicationQueueStorage.removeLastSequenceIds(String peerId, List<String> encodedRegionNames)
void	ReplicationQueueStorage.removeLastSequenceIdsAndHFileRefsBefore(long ts)	Remove all the last sequence ids and hfile references data which are written before the given timestamp.
void	TableReplicationQueueStorage.removeLastSequenceIdsAndHFileRefsBefore(long ts)
void	FSReplicationPeerStorage.removePeer(String peerId)
void	ReplicationPeerStorage.removePeer(String peerId)	Remove a replication peer.
void	ZKReplicationPeerStorage.removePeer(String peerId)
void	ReplicationQueueStorage.removePeerFromHFileRefs(String peerId)	Remove a peer from hfile reference queue.
void	TableReplicationQueueStorage.removePeerFromHFileRefs(String peerId)
void	ReplicationQueueStorage.removeQueue(ReplicationQueueId queueId)	Remove a replication queue
void	TableReplicationQueueStorage.removeQueue(ReplicationQueueId queueId)
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.setLastSequenceIds(String peerId, 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	TableReplicationQueueStorage.setOffset(ReplicationQueueId queueId, String walGroup, ReplicationGroupOffset offset, Map<String,Long> lastSeqIds)
void	FSReplicationPeerStorage.setPeerNewSyncReplicationState(String peerId, SyncReplicationState newState)
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.setPeerState(String peerId, boolean enabled)
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.transitPeerSyncReplicationState(String peerId)
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.updatePeerConfig(String peerId, ReplicationPeerConfig peerConfig)
void	ReplicationPeerStorage.updatePeerConfig(String peerId, ReplicationPeerConfig peerConfig)	Update the config a replication peer.
void	ZKReplicationPeerStorage.updatePeerConfig(String peerId, ReplicationPeerConfig peerConfig)

Uses of ReplicationException in org.apache.hadoop.hbase.replication.regionserver

Methods in org.apache.hadoop.hbase.replication.regionserver that throw ReplicationException

Modifier and Type	Method	Description
void	ReplicationSource.addHFileRefs(TableName tableName, byte[] family, List<Pair<org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> pairs)
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.
private void	ReplicationSyncUp.addMissingReplicationQueues(ReplicationQueueStorage storage, Set<ServerName> regionServers, Set<String> peerIds)
private void	ReplicationSyncUp.addMissingReplicationQueues(ReplicationQueueStorage storage, ServerName regionServer, Set<String> peerIds)
void	PeerProcedureHandler.addPeer(String peerId)
void	PeerProcedureHandler.claimReplicationQueue(ReplicationQueueId queueId)
void	PeerProcedureHandlerImpl.claimReplicationQueue(ReplicationQueueId queueId)
private void	ReplicationSyncUp.claimReplicationQueues(ReplicationSourceManager mgr, Set<ServerName> regionServers)
private ReplicationSourceInterface	ReplicationSourceManager.createRefreshedSource(ReplicationQueueId queueId, ReplicationPeer peer)
void	PeerProcedureHandler.disablePeer(String peerId)
void	PeerProcedureHandlerImpl.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	PeerProcedureHandler.enablePeer(String peerId)
void	PeerProcedureHandlerImpl.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	PeerProcedureHandler.transitSyncReplicationPeerState(String peerId, int stage, HRegionServer rs)
void	PeerProcedureHandlerImpl.transitSyncReplicationPeerState(String peerId, int stage, HRegionServer rs)
void	PeerProcedureHandler.updatePeerConfig(String peerId)
void	PeerProcedureHandlerImpl.updatePeerConfig(String peerId)

Uses of ReplicationException in org.apache.hadoop.hbase.util

Methods in org.apache.hadoop.hbase.util that throw ReplicationException

Modifier and Type	Method	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

Uses of ReplicationException in org.apache.hadoop.hbase.util.hbck

Methods in org.apache.hadoop.hbase.util.hbck that throw ReplicationException

Modifier and Type	Method	Description
boolean	ReplicationChecker.checkHasDataInQueues()
void	ReplicationChecker.checkUnDeletedQueues()
void	ReplicationChecker.fixUnDeletedQueues()
private Set<String>	ReplicationChecker.getUndeletedHFileRefsPeers()
private Map<ServerName,List<ReplicationQueueId>>	ReplicationChecker.getUnDeletedQueues()