Package org.apache.hadoop.hbase.replication

Class ReplicationPeerImpl

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationPeerImpl

All Implemented Interfaces:

ConfigurationObserver, ReplicationPeer

@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 static final int	AND_BITS
private org.apache.hadoop.conf.Configuration	conf
private final String	id
private ReplicationPeerConfig	peerConfig
private final List<ReplicationPeerConfigListener>	peerConfigListeners
private ReplicationPeer.PeerState	peerState
private static final int	SHIFT
private int	syncReplicationStateBits

Constructor Summary

Constructors

Constructor	Description
ReplicationPeerImpl(org.apache.hadoop.conf.Configuration conf, String id, ReplicationPeerConfig peerConfig, boolean peerState, SyncReplicationState syncReplicationState, SyncReplicationState newSyncReplicationState)	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
SyncReplicationState	getNewSyncReplicationState()
private static SyncReplicationState	getNewSyncReplicationState(int bits)
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.
SyncReplicationState	getSyncReplicationState()	Returns the sync replication state of the peer by reading local cache.
private static SyncReplicationState	getSyncReplicationState(int bits)
Pair<SyncReplicationState,SyncReplicationState>	getSyncReplicationStateAndNewState()
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	setNewSyncReplicationState(SyncReplicationState newState)
void	setPeerConfig(ReplicationPeerConfig peerConfig)
void	setPeerState(boolean enabled)
void	transitSyncReplicationState()

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

syncReplicationStateBits

private volatile int syncReplicationStateBits

SHIFT

private static final int SHIFT

See Also:

• Constant Field Values

AND_BITS

private static final int AND_BITS

See Also:

• Constant Field Values

peerConfigListeners

private final List<ReplicationPeerConfigListener> peerConfigListeners

Constructor Details

ReplicationPeerImpl

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

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)

setNewSyncReplicationState

public void setNewSyncReplicationState(SyncReplicationState newState)

transitSyncReplicationState

public void transitSyncReplicationState()

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

getSyncReplicationState

private static SyncReplicationState getSyncReplicationState(int bits)

getNewSyncReplicationState

private static SyncReplicationState getNewSyncReplicationState(int bits)

getSyncReplicationStateAndNewState

public Pair<SyncReplicationState,SyncReplicationState> getSyncReplicationStateAndNewState()

getNewSyncReplicationState

public SyncReplicationState getNewSyncReplicationState()

getSyncReplicationState

public SyncReplicationState getSyncReplicationState()

Description copied from interface: ReplicationPeer

Returns the sync replication state of the peer by reading local cache.

If the peer is not a synchronous replication peer, a SyncReplicationState.NONE will be returned.

Specified by:

getSyncReplicationState in interface ReplicationPeer

Returns:

the sync replication state

getPeerConfig

public ReplicationPeerConfig getPeerConfig()

Description copied from interface: ReplicationPeer

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()

Description copied from interface: ReplicationPeer

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()

Description copied from interface: ReplicationPeer

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()

Description copied from interface: ReplicationPeer

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