org.apache.hadoop.hbase.replication

Class ReplicationPeers

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationPeers

@InterfaceAudience.Private
public class ReplicationPeers
extends Object

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

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.conf.Configuration	conf
private ConcurrentMap<String,ReplicationPeerImpl>	peerCache
private ReplicationPeerStorage	peerStorage

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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()
ReplicationPeerConfig	refreshPeerConfig(String peerId)
ReplicationPeer.PeerState	refreshPeerState(String peerId)
void	removePeer(String peerId)

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

peerCache

private final ConcurrentMap<String,ReplicationPeerImpl> peerCache

peerStorage

private final ReplicationPeerStorage peerStorage

Constructor Detail

ReplicationPeers

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

Method Detail

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

removePeer

public void 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

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