org.apache.hadoop.hbase.replication

Class ZKReplicationPeerStorage

java.lang.Object

org.apache.hadoop.hbase.replication.ZKReplicationStorageBase

org.apache.hadoop.hbase.replication.ZKReplicationPeerStorage

All Implemented Interfaces:

ReplicationPeerStorage

@InterfaceAudience.Private
public class ZKReplicationPeerStorage
extends ZKReplicationStorageBase
implements ReplicationPeerStorage

ZK based replication peer storage.

Field Summary

Fields

Modifier and Type	Field and Description
static byte[]	DISABLED_ZNODE_BYTES
static byte[]	ENABLED_ZNODE_BYTES
static String	PEERS_STATE_ZNODE
static String	PEERS_STATE_ZNODE_DEFAULT
static String	PEERS_ZNODE
static String	PEERS_ZNODE_DEFAULT
private String	peerStateNodeName The name of the znode that contains the replication status of a remote slave (i.e.
private String	peersZNode The name of the znode that contains a list of all remote slave (i.e.

Fields inherited from class org.apache.hadoop.hbase.replication.ZKReplicationStorageBase

conf, REPLICATION_ZNODE, REPLICATION_ZNODE_DEFAULT, replicationZNode, zookeeper

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	addPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled) Add a replication peer.
ReplicationPeerConfig	getPeerConfig(String peerId) Get the peer config of a replication peer.
String	getPeerNode(String peerId)
String	getPeerStateNode(String peerId)
boolean	isPeerEnabled(String peerId) Test whether a replication peer is enabled.
List<String>	listPeerIds() Return the peer ids of all replication peers.
void	removePeer(String peerId) Remove a replication peer.
void	setPeerState(String peerId, boolean enabled) Set the state of peer, true to ENABLED, otherwise to DISABLED.
void	updatePeerConfig(String peerId, ReplicationPeerConfig peerConfig) Update the config a replication peer.

Methods inherited from class org.apache.hadoop.hbase.replication.ZKReplicationStorageBase

toByteArray

Methods inherited from class java.lang.Object

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

Field Detail

PEERS_ZNODE

public static final String PEERS_ZNODE

See Also:

Constant Field Values

PEERS_ZNODE_DEFAULT

public static final String PEERS_ZNODE_DEFAULT

See Also:

Constant Field Values

PEERS_STATE_ZNODE

public static final String PEERS_STATE_ZNODE

See Also:

Constant Field Values

PEERS_STATE_ZNODE_DEFAULT

public static final String PEERS_STATE_ZNODE_DEFAULT

See Also:

Constant Field Values

ENABLED_ZNODE_BYTES

public static final byte[] ENABLED_ZNODE_BYTES

DISABLED_ZNODE_BYTES

public static final byte[] DISABLED_ZNODE_BYTES

peerStateNodeName

private final String peerStateNodeName

The name of the znode that contains the replication status of a remote slave (i.e. peer) cluster.

peersZNode

private final String peersZNode

The name of the znode that contains a list of all remote slave (i.e. peer) clusters.

Constructor Detail

ZKReplicationPeerStorage

public ZKReplicationPeerStorage(ZKWatcher zookeeper,
                                org.apache.hadoop.conf.Configuration conf)

Method Detail

getPeerStateNode

public String getPeerStateNode(String peerId)

getPeerNode

public String getPeerNode(String peerId)

addPeer

public void addPeer(String peerId,
                    ReplicationPeerConfig peerConfig,
                    boolean enabled)
             throws ReplicationException

Description copied from interface: ReplicationPeerStorage

Add a replication peer.

Specified by:

addPeer in interface ReplicationPeerStorage

Throws:

ReplicationException - if there are errors accessing the storage service.

removePeer

public void removePeer(String peerId)
                throws ReplicationException

Description copied from interface: ReplicationPeerStorage

Remove a replication peer.

Specified by:

removePeer in interface ReplicationPeerStorage

Throws:

ReplicationException - if there are errors accessing the storage service.

setPeerState

public void setPeerState(String peerId,
                         boolean enabled)
                  throws ReplicationException

Description copied from interface: ReplicationPeerStorage

Set the state of peer, true to ENABLED, otherwise to DISABLED.

Specified by:

setPeerState in interface ReplicationPeerStorage

Throws:

ReplicationException - if there are errors accessing the storage service.

updatePeerConfig

public void updatePeerConfig(String peerId,
                             ReplicationPeerConfig peerConfig)
                      throws ReplicationException

Description copied from interface: ReplicationPeerStorage

Update the config a replication peer.

Specified by:

updatePeerConfig in interface ReplicationPeerStorage

Throws:

ReplicationException - if there are errors accessing the storage service.

listPeerIds

public List<String> listPeerIds()
                         throws ReplicationException

Description copied from interface: ReplicationPeerStorage

Return the peer ids of all replication peers.

Specified by:

listPeerIds in interface ReplicationPeerStorage

Throws:

ReplicationException - if there are errors accessing the storage service.

isPeerEnabled

public boolean isPeerEnabled(String peerId)
                      throws ReplicationException

Description copied from interface: ReplicationPeerStorage

Test whether a replication peer is enabled.

Specified by:

isPeerEnabled in interface ReplicationPeerStorage

Throws:

ReplicationException - if there are errors accessing the storage service.

getPeerConfig

public ReplicationPeerConfig getPeerConfig(String peerId)
                                    throws ReplicationException

Description copied from interface: ReplicationPeerStorage

Get the peer config of a replication peer.

Specified by:

getPeerConfig in interface ReplicationPeerStorage

Throws:

ReplicationException - if there are errors accessing the storage service.