org.apache.hadoop.hbase.master.replication

Class ReplicationManager

java.lang.Object

org.apache.hadoop.hbase.master.replication.ReplicationManager

@InterfaceAudience.Private
public class ReplicationManager
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.hadoop.conf.Configuration	conf
private ReplicationPeers	replicationPeers
private ReplicationQueuesClient	replicationQueuesClient
private ZKWatcher	zkw

Constructor Summary

Constructors

Constructor and Description
ReplicationManager(org.apache.hadoop.conf.Configuration conf, ZKWatcher zkw, Abortable abortable)

Method Summary

Modifier and Type	Method and Description
void	addReplicationPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled)
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) If replicate_all flag is true, it means all user tables will be replicated to peer cluster.
void	disableReplicationPeer(String peerId)
void	enableReplicationPeer(String peerId)
ReplicationPeerConfig	getPeerConfig(String peerId)
List<ReplicationPeerDescription>	listReplicationPeers(Pattern pattern)
void	removeReplicationPeer(String peerId)
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

conf

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

zkw

private final ZKWatcher zkw

replicationQueuesClient

private final ReplicationQueuesClient replicationQueuesClient

replicationPeers

private final ReplicationPeers replicationPeers

Constructor Detail

ReplicationManager

public ReplicationManager(org.apache.hadoop.conf.Configuration conf,
                          ZKWatcher zkw,
                          Abortable abortable)
                   throws IOException

Throws:

IOException

Method Detail

addReplicationPeer

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

Throws:

ReplicationException

IOException

removeReplicationPeer

public void removeReplicationPeer(String peerId)
                           throws ReplicationException

Throws:

ReplicationException

enableReplicationPeer

public void enableReplicationPeer(String peerId)
                           throws ReplicationException

Throws:

ReplicationException

disableReplicationPeer

public void disableReplicationPeer(String peerId)
                            throws ReplicationException

Throws:

ReplicationException

getPeerConfig

public ReplicationPeerConfig getPeerConfig(String peerId)
                                    throws ReplicationException,
                                           ReplicationPeerNotFoundException

Throws:

ReplicationException

ReplicationPeerNotFoundException

updatePeerConfig

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

Throws:

ReplicationException

IOException

listReplicationPeers

public List<ReplicationPeerDescription> listReplicationPeers(Pattern pattern)
                                                      throws ReplicationException

Throws:

ReplicationException

checkPeerConfig

private void checkPeerConfig(ReplicationPeerConfig peerConfig)
                      throws ReplicationException,
                             IOException

If replicate_all flag is true, it means all user tables will be replicated to peer cluster. Then allow config exclude namespaces or exclude table-cfs which can't be replicated to peer cluster. If replicate_all flag is false, it means all user tables can't be replicated to peer cluster. Then allow to config namespaces or table-cfs which will be replicated to peer cluster.

Throws:

ReplicationException

IOException

checkNamespacesAndTableCfsConfigConflict

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

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:

ReplicationException

checkConfiguredWALEntryFilters

private void checkConfiguredWALEntryFilters(ReplicationPeerConfig peerConfig)
                                     throws IOException

Throws:

IOException