Package org.apache.hadoop.hbase.replication

Class ReplicationPeers

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationPeers

All Implemented Interfaces:

ConfigurationObserver

@Private
public class ReplicationPeers
extends Object
implements ConfigurationObserver

This provides an class for maintaining a set of peer clusters. These peers are remote slave clusters that data is replicated to.

We implement ConfigurationObserver mainly for recreating the ReplicationPeerStorage, so we can change the ReplicationPeerStorage without restarting the region server.

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.conf.Configuration	conf
private final org.apache.hadoop.fs.FileSystem	fs
private static final org.slf4j.Logger	LOG
private final ConcurrentMap<String,ReplicationPeerImpl>	peerCache
private ReplicationPeerStorage	peerStorage
private final ZKWatcher	zookeeper

Constructor Summary

Constructors

Constructor	Description
ReplicationPeers(org.apache.hadoop.fs.FileSystem fs, ZKWatcher zookeeper, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
boolean	addPeer(String peerId)	Method called after a peer has been connected.
private ReplicationPeerImpl	createPeer(String peerId)	Helper method to connect to a peer
Set<String>	getAllPeerIds()	Returns the set of peerIds of the clusters that have been connected and have an underlying ReplicationPeer.
org.apache.hadoop.conf.Configuration	getConf()
ReplicationPeerImpl	getPeer(String peerId)	Returns the ReplicationPeerImpl for the specified cached peer.
Map<String,ReplicationPeerImpl>	getPeerCache()
ReplicationPeerStorage	getPeerStorage()
void	init()
void	onConfigurationChange(org.apache.hadoop.conf.Configuration conf)	This method would be called by the ConfigurationManager object when the Configuration object is reloaded from disk.
ReplicationPeerConfig	refreshPeerConfig(String peerId)
SyncReplicationState	refreshPeerNewSyncReplicationState(String peerId)
ReplicationPeer.PeerState	refreshPeerState(String peerId)
ReplicationPeerImpl	removePeer(String peerId)
void	transitPeerSyncReplicationState(String peerId)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

conf

private volatile org.apache.hadoop.conf.Configuration conf

peerCache

private final ConcurrentMap<String,ReplicationPeerImpl> peerCache

fs

private final org.apache.hadoop.fs.FileSystem fs

zookeeper

private final ZKWatcher zookeeper

peerStorage

private volatile ReplicationPeerStorage peerStorage

Constructor Details

ReplicationPeers

ReplicationPeers(org.apache.hadoop.fs.FileSystem fs,
 ZKWatcher zookeeper,
 org.apache.hadoop.conf.Configuration conf)

Method Details

getConf

public org.apache.hadoop.conf.Configuration getConf()

init

public void init()
          throws ReplicationException

Throws:

ReplicationException

getPeerStorage

public ReplicationPeerStorage getPeerStorage()

addPeer

public boolean addPeer(String peerId)
                throws ReplicationException

Method called after a peer has been connected. It will create a ReplicationPeer to track the newly connected cluster.

Parameters:

peerId - a short that identifies the cluster

Returns:

whether a ReplicationPeer was successfully created

Throws:

ReplicationException - if connecting to the peer fails

removePeer

public ReplicationPeerImpl removePeer(String peerId)

getPeer

public ReplicationPeerImpl getPeer(String peerId)

Returns the ReplicationPeerImpl for the specified cached peer. This ReplicationPeer will continue to track changes to the Peer's state and config. This method returns null if no peer has been cached with the given peerId.

Parameters:

peerId - id for the peer

Returns:

ReplicationPeer object

getAllPeerIds

public Set<String> getAllPeerIds()

Returns the set of peerIds of the clusters that have been connected and have an underlying ReplicationPeer.

Returns:

a Set of Strings for peerIds

getPeerCache

public Map<String,ReplicationPeerImpl> getPeerCache()

refreshPeerState

public ReplicationPeer.PeerState refreshPeerState(String peerId)
                                           throws ReplicationException

Throws:

ReplicationException

refreshPeerConfig

public ReplicationPeerConfig refreshPeerConfig(String peerId)
                                        throws ReplicationException

Throws:

ReplicationException

refreshPeerNewSyncReplicationState

public SyncReplicationState refreshPeerNewSyncReplicationState(String peerId)
                                                        throws ReplicationException

Throws:

ReplicationException

transitPeerSyncReplicationState

public void transitPeerSyncReplicationState(String peerId)

createPeer

private ReplicationPeerImpl createPeer(String peerId)
                                throws ReplicationException

Helper method to connect to a peer

Parameters:

peerId - peer's identifier

Returns:

object representing the peer

Throws:

ReplicationException

onConfigurationChange

public void onConfigurationChange(org.apache.hadoop.conf.Configuration conf)

Description copied from interface: ConfigurationObserver

This method would be called by the ConfigurationManager object when the Configuration object is reloaded from disk.

Specified by:

onConfigurationChange in interface ConfigurationObserver