Package org.apache.hadoop.hbase.replication

Class ReplicationPeerImpl

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationPeerImpl

All Implemented Interfaces:

ConfigurationObserver, ReplicationPeer

Direct Known Subclasses:

CatalogReplicationSourcePeer

@Private
public class ReplicationPeerImpl
extends Object
implements ReplicationPeer, ConfigurationObserver

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.replication.ReplicationPeer

ReplicationPeer.PeerState

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.conf.Configuration	conf
private final String	id
private ReplicationPeerConfig	peerConfig
private final List<ReplicationPeerConfigListener>	peerConfigListeners
private ReplicationPeer.PeerState	peerState

Constructor Summary

Constructors

Constructor	Description
ReplicationPeerImpl(org.apache.hadoop.conf.Configuration conf, String id, boolean peerState, ReplicationPeerConfig peerConfig)	Constructor that takes all the objects required to communicate with the specified peer, except for the region server addresses.

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.conf.Configuration	getConfiguration()	Get the configuration object required to communicate with this peer
String	getId()	Get the identifier of this peer
Set<String>	getNamespaces()	Get replicable namespace set of this peer
long	getPeerBandwidth()	Get the per node bandwidth upper limit for this peer
ReplicationPeerConfig	getPeerConfig()	Get the peer config object
ReplicationPeer.PeerState	getPeerState()	Returns the state of the peer by reading local cache.
Map<TableName,List<String>>	getTableCFs()	Get replicable (table, cf-list) map of this peer
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.
void	registerPeerConfigListener(ReplicationPeerConfigListener listener)	Register a peer config listener to catch the peer config change event.
void	setPeerConfig(ReplicationPeerConfig peerConfig)
void	setPeerState(boolean enabled)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.replication.ReplicationPeer

isPeerEnabled, trackPeerConfigChanges

Field Details

conf

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

id

private final String id

peerConfig

private volatile ReplicationPeerConfig peerConfig

peerState

private volatile ReplicationPeer.PeerState peerState

peerConfigListeners

private final List<ReplicationPeerConfigListener> peerConfigListeners

Constructor Details

ReplicationPeerImpl

public ReplicationPeerImpl(org.apache.hadoop.conf.Configuration conf,
 String id,
 boolean peerState,
 ReplicationPeerConfig peerConfig)

Constructor that takes all the objects required to communicate with the specified peer, except for the region server addresses.

Parameters:

conf - configuration object to this peer

id - string representation of this peer's identifier

peerConfig - configuration for the replication peer

Method Details

setPeerState

public void setPeerState(boolean enabled)

setPeerConfig

public void setPeerConfig(ReplicationPeerConfig peerConfig)

getId

public String getId()

Get the identifier of this peer

Specified by:

getId in interface ReplicationPeer

Returns:

string representation of the id (short)

getPeerState

public ReplicationPeer.PeerState getPeerState()

Description copied from interface: ReplicationPeer

Returns the state of the peer by reading local cache.

Specified by:

getPeerState in interface ReplicationPeer

Returns:

the enabled state

getPeerConfig

public ReplicationPeerConfig getPeerConfig()

Get the peer config object

Specified by:

getPeerConfig in interface ReplicationPeer

Returns:

the ReplicationPeerConfig for this peer

getConfiguration

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

Get the configuration object required to communicate with this peer

Specified by:

getConfiguration in interface ReplicationPeer

Returns:

configuration object

getTableCFs

public Map<TableName,List<String>> getTableCFs()

Get replicable (table, cf-list) map of this peer

Specified by:

getTableCFs in interface ReplicationPeer

Returns:

the replicable (table, cf-list) map

getNamespaces

public Set<String> getNamespaces()

Get replicable namespace set of this peer

Specified by:

getNamespaces in interface ReplicationPeer

Returns:

the replicable namespaces set

getPeerBandwidth

public long getPeerBandwidth()

Description copied from interface: ReplicationPeer

Get the per node bandwidth upper limit for this peer

Specified by:

getPeerBandwidth in interface ReplicationPeer

Returns:

the bandwidth upper limit

registerPeerConfigListener

public void registerPeerConfigListener(ReplicationPeerConfigListener listener)

Description copied from interface: ReplicationPeer

Register a peer config listener to catch the peer config change event.

Specified by:

registerPeerConfigListener in interface ReplicationPeer

Parameters:

listener - listener to catch the peer config change event.

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