org.apache.hadoop.hbase.replication

Interface ReplicationPeer

All Known Implementing Classes:

ReplicationPeerZKImpl

@InterfaceAudience.LimitedPrivate(value="Replication")
public interface ReplicationPeer

ReplicationPeer manages enabled / disabled state for the peer.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	ReplicationPeer.PeerState State of the peer, whether it is enabled or not

Method Summary

Modifier and Type	Method and 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
Map<TableName,List<String>>	getTableCFs() Get replicable (table, cf-list) map of this peer
void	trackPeerConfigChanges(ReplicationPeerConfigListener listener)

Method Detail

getId

String getId()

Get the identifier of this peer

Returns:

string representation of the id

getPeerConfig

ReplicationPeerConfig getPeerConfig()

Get the peer config object

Returns:

the ReplicationPeerConfig for this peer

getPeerState

ReplicationPeer.PeerState getPeerState()

Returns the state of the peer

Returns:

the enabled state

getConfiguration

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

Get the configuration object required to communicate with this peer

Returns:

configuration object

getTableCFs

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

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

Returns:

the replicable (table, cf-list) map

getNamespaces

Set<String> getNamespaces()

Get replicable namespace set of this peer

Returns:

the replicable namespaces set

getPeerBandwidth

long getPeerBandwidth()

Get the per node bandwidth upper limit for this peer

Returns:

the bandwidth upper limit

trackPeerConfigChanges

void trackPeerConfigChanges(ReplicationPeerConfigListener listener)