org.apache.hadoop.hbase.master.replication

Class ReplicationPeerManager

java.lang.Object

org.apache.hadoop.hbase.master.replication.ReplicationPeerManager

@InterfaceAudience.Private
public class ReplicationPeerManager
extends Object

Manages and performs all replication admin operations.

Used to add/remove a replication peer.

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<SyncReplicationState,EnumSet<SyncReplicationState>>	allowedTransition
private String	clusterId
private org.apache.hadoop.conf.Configuration	conf
private ConcurrentMap<String,ReplicationPeerDescription>	peers
private ReplicationPeerStorage	peerStorage
private ReplicationQueueStorage	queueStorage
private Semaphore	syncReplicationPeerLock

Constructor Summary

Constructors

Constructor and Description
ReplicationPeerManager(ReplicationPeerStorage peerStorage, ReplicationQueueStorage queueStorage, ConcurrentMap<String,ReplicationPeerDescription> peers, org.apache.hadoop.conf.Configuration conf, String clusterId)

Method Summary

Modifier and Type	Method and Description
void	acquireSyncReplicationPeerLock()
void	addPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled)
private void	checkClusterId(String clusterKey)
private void	checkClusterKey(String clusterKey)
private void	checkConfiguredWALEntryFilters(ReplicationPeerConfig peerConfig)
private void	checkNamespacesAndTableCfsConfigConflict(Set<String> namespaces, Map<TableName,? extends Collection<String>> tableCfs) Set a namespace in the peer config means that all tables in this namespace will be replicated to the peer cluster.
private void	checkPeerConfig(ReplicationPeerConfig peerConfig)
private void	checkPeerConfigForSyncReplication(ReplicationPeerConfig peerConfig)
private ReplicationPeerDescription	checkPeerExists(String peerId)
private void	checkPeerInDAStateIfSyncReplication(String peerId)
private void	checkQueuesDeleted(String peerId)
private void	checkSyncReplicationPeerConfigConflict(ReplicationPeerConfig peerConfig)
static ReplicationPeerManager	create(ZKWatcher zk, org.apache.hadoop.conf.Configuration conf, String clusterId)
void	disablePeer(String peerId)
void	enablePeer(String peerId)
Optional<ReplicationPeerConfig>	getPeerConfig(String peerId)
ReplicationQueueStorage	getQueueStorage()
List<String>	getSerialPeerIdsBelongsTo(TableName tableName)
private boolean	isStringEquals(String s1, String s2) For replication peer cluster key or endpoint class, null and empty string is same.
List<ReplicationPeerDescription>	listPeers(Pattern pattern)
(package private) void	preAddPeer(String peerId, ReplicationPeerConfig peerConfig)
(package private) void	preDisablePeer(String peerId)
(package private) void	preEnablePeer(String peerId)
(package private) ReplicationPeerConfig	preRemovePeer(String peerId)
(package private) ReplicationPeerDescription	preTransitPeerSyncReplicationState(String peerId, SyncReplicationState state)
(package private) ReplicationPeerDescription	preUpdatePeerConfig(String peerId, ReplicationPeerConfig peerConfig) Return the old peer description.
void	releaseSyncReplicationPeerLock()
(package private) void	removeAllLastPushedSeqIds(String peerId)
void	removeAllQueues(String peerId)
void	removeAllQueuesAndHFileRefs(String peerId)
void	removePeer(String peerId)
void	setPeerNewSyncReplicationState(String peerId, SyncReplicationState state)
private void	setPeerState(String peerId, boolean enabled)
void	transitPeerSyncReplicationState(String peerId, SyncReplicationState newState)
void	updatePeerConfig(String peerId, ReplicationPeerConfig peerConfig)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

peerStorage

private final ReplicationPeerStorage peerStorage

queueStorage

private final ReplicationQueueStorage queueStorage

peers

private final ConcurrentMap<String,ReplicationPeerDescription> peers

allowedTransition

private final org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<SyncReplicationState,EnumSet<SyncReplicationState>> allowedTransition

syncReplicationPeerLock

private final Semaphore syncReplicationPeerLock

clusterId

private final String clusterId

conf

private final org.apache.hadoop.conf.Configuration conf

Constructor Detail

ReplicationPeerManager

ReplicationPeerManager(ReplicationPeerStorage peerStorage,
                       ReplicationQueueStorage queueStorage,
                       ConcurrentMap<String,ReplicationPeerDescription> peers,
                       org.apache.hadoop.conf.Configuration conf,
                       String clusterId)

Method Detail

checkQueuesDeleted

private void checkQueuesDeleted(String peerId)
                         throws ReplicationException,
                                DoNotRetryIOException

Throws:

ReplicationException

DoNotRetryIOException

preAddPeer

void preAddPeer(String peerId,
                ReplicationPeerConfig peerConfig)
         throws DoNotRetryIOException,
                ReplicationException

Throws:

DoNotRetryIOException

ReplicationException

checkPeerExists

private ReplicationPeerDescription checkPeerExists(String peerId)
                                            throws DoNotRetryIOException

Throws:

DoNotRetryIOException

checkPeerInDAStateIfSyncReplication

private void checkPeerInDAStateIfSyncReplication(String peerId)
                                          throws DoNotRetryIOException

Throws:

DoNotRetryIOException

preRemovePeer

ReplicationPeerConfig preRemovePeer(String peerId)
                             throws DoNotRetryIOException

Throws:

DoNotRetryIOException

preEnablePeer

void preEnablePeer(String peerId)
            throws DoNotRetryIOException

Throws:

DoNotRetryIOException

preDisablePeer

void preDisablePeer(String peerId)
             throws DoNotRetryIOException

Throws:

DoNotRetryIOException

preUpdatePeerConfig

ReplicationPeerDescription preUpdatePeerConfig(String peerId,
                                               ReplicationPeerConfig peerConfig)
                                        throws DoNotRetryIOException

Return the old peer description. Can never be null.

Throws:

DoNotRetryIOException

preTransitPeerSyncReplicationState

ReplicationPeerDescription preTransitPeerSyncReplicationState(String peerId,
                                                              SyncReplicationState state)
                                                       throws DoNotRetryIOException

Returns:

the old desciption of the peer

Throws:

DoNotRetryIOException

addPeer

public void addPeer(String peerId,
                    ReplicationPeerConfig peerConfig,
                    boolean enabled)
             throws ReplicationException

Throws:

ReplicationException

removePeer

public void removePeer(String peerId)
                throws ReplicationException

Throws:

ReplicationException

setPeerState

private void setPeerState(String peerId,
                          boolean enabled)
                   throws ReplicationException

Throws:

ReplicationException

enablePeer

public void enablePeer(String peerId)
                throws ReplicationException

Throws:

ReplicationException

disablePeer

public void disablePeer(String peerId)
                 throws ReplicationException

Throws:

ReplicationException

updatePeerConfig

public void updatePeerConfig(String peerId,
                             ReplicationPeerConfig peerConfig)
                      throws ReplicationException

Throws:

ReplicationException

listPeers

public List<ReplicationPeerDescription> listPeers(Pattern pattern)

getPeerConfig

public Optional<ReplicationPeerConfig> getPeerConfig(String peerId)

removeAllLastPushedSeqIds

void removeAllLastPushedSeqIds(String peerId)
                        throws ReplicationException

Throws:

ReplicationException

setPeerNewSyncReplicationState

public void setPeerNewSyncReplicationState(String peerId,
                                           SyncReplicationState state)
                                    throws ReplicationException

Throws:

ReplicationException

transitPeerSyncReplicationState

public void transitPeerSyncReplicationState(String peerId,
                                            SyncReplicationState newState)
                                     throws ReplicationException

Throws:

ReplicationException

removeAllQueues

public void removeAllQueues(String peerId)
                     throws ReplicationException

Throws:

ReplicationException

removeAllQueuesAndHFileRefs

public void removeAllQueuesAndHFileRefs(String peerId)
                                 throws ReplicationException

Throws:

ReplicationException

checkPeerConfig

private void checkPeerConfig(ReplicationPeerConfig peerConfig)
                      throws DoNotRetryIOException

Throws:

DoNotRetryIOException

checkPeerConfigForSyncReplication

private void checkPeerConfigForSyncReplication(ReplicationPeerConfig peerConfig)
                                        throws DoNotRetryIOException

Throws:

DoNotRetryIOException

checkSyncReplicationPeerConfigConflict

private void checkSyncReplicationPeerConfigConflict(ReplicationPeerConfig peerConfig)
                                             throws DoNotRetryIOException

Throws:

DoNotRetryIOException

checkNamespacesAndTableCfsConfigConflict

private void checkNamespacesAndTableCfsConfigConflict(Set<String> namespaces,
                                                      Map<TableName,? extends Collection<String>> tableCfs)
                                               throws DoNotRetryIOException

Set a namespace in the peer config means that all tables in this namespace will be replicated to the peer cluster.

1. If peer config already has a namespace, then not allow set any table of this namespace to the peer config.
2. If peer config already has a table, then not allow set this table's namespace to the peer config.

Set a exclude namespace in the peer config means that all tables in this namespace can't be replicated to the peer cluster.

1. If peer config already has a exclude namespace, then not allow set any exclude table of this namespace to the peer config.
2. If peer config already has a exclude table, then not allow set this table's namespace as a exclude namespace.

Throws:

DoNotRetryIOException

checkConfiguredWALEntryFilters

private void checkConfiguredWALEntryFilters(ReplicationPeerConfig peerConfig)
                                     throws DoNotRetryIOException

Throws:

DoNotRetryIOException

checkClusterKey

private void checkClusterKey(String clusterKey)
                      throws DoNotRetryIOException

Throws:

DoNotRetryIOException

checkClusterId

private void checkClusterId(String clusterKey)
                     throws DoNotRetryIOException

Throws:

DoNotRetryIOException

getSerialPeerIdsBelongsTo

public List<String> getSerialPeerIdsBelongsTo(TableName tableName)

getQueueStorage

public ReplicationQueueStorage getQueueStorage()

create

public static ReplicationPeerManager create(ZKWatcher zk,
                                            org.apache.hadoop.conf.Configuration conf,
                                            String clusterId)
                                     throws ReplicationException

Throws:

ReplicationException

isStringEquals

private boolean isStringEquals(String s1,
                               String s2)

For replication peer cluster key or endpoint class, null and empty string is same. So here don't use StringUtils.equals(CharSequence, CharSequence) directly.

acquireSyncReplicationPeerLock

public void acquireSyncReplicationPeerLock()
                                    throws InterruptedException

Throws:

InterruptedException

releaseSyncReplicationPeerLock

public void releaseSyncReplicationPeerLock()