Package 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

@Private
public class ZKReplicationPeerStorage
extends ZKReplicationStorageBase
implements ReplicationPeerStorage

ZK based replication peer storage.

Field Summary

Fields

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

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

conf, REPLICATION_ZNODE, REPLICATION_ZNODE_DEFAULT, replicationZNode, zookeeper

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	addPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled, SyncReplicationState syncReplicationState)	Add a replication peer.
String	getNewSyncReplicationStateNode(String peerId)
ReplicationPeerConfig	getPeerConfig(String peerId)	Get the peer config of a replication peer.
SyncReplicationState	getPeerNewSyncReplicationState(String peerId)	Get the new sync replication state.
String	getPeerNode(String peerId)
String	getPeerStateNode(String peerId)
SyncReplicationState	getPeerSyncReplicationState(String peerId)	Get the sync replication state.
private SyncReplicationState	getSyncReplicationState(String peerId, String path)
String	getSyncReplicationStateNode(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	setPeerNewSyncReplicationState(String peerId, SyncReplicationState state)	Set the new sync replication state that we are going to transit to.
void	setPeerState(String peerId, boolean enabled)	Set the state of peer, true to ENABLED, otherwise to DISABLED.
void	transitPeerSyncReplicationState(String peerId)	Overwrite the sync replication state with the new sync replication state which is set with the ReplicationPeerStorage.setPeerNewSyncReplicationState(String, SyncReplicationState) method above, and clear the new sync replication state.
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 Details

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

SYNC_REPLICATION_STATE_ZNODE

public static final String SYNC_REPLICATION_STATE_ZNODE

See Also:

• Constant Field Values

NEW_SYNC_REPLICATION_STATE_ZNODE

public static final String NEW_SYNC_REPLICATION_STATE_ZNODE

See Also:

• Constant Field Values

NONE_STATE_ZNODE_BYTES

public static final byte[] NONE_STATE_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 Details

ZKReplicationPeerStorage

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

Method Details

getPeerStateNode

public String getPeerStateNode(String peerId)

getPeerNode

public String getPeerNode(String peerId)

getSyncReplicationStateNode

public String getSyncReplicationStateNode(String peerId)

getNewSyncReplicationStateNode

public String getNewSyncReplicationStateNode(String peerId)

addPeer

public void addPeer(String peerId,
 ReplicationPeerConfig peerConfig,
 boolean enabled,
 SyncReplicationState syncReplicationState)
             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.

setPeerNewSyncReplicationState

public void setPeerNewSyncReplicationState(String peerId,
 SyncReplicationState state)
                                    throws ReplicationException

Description copied from interface: ReplicationPeerStorage

Set the new sync replication state that we are going to transit to.

Specified by:

setPeerNewSyncReplicationState in interface ReplicationPeerStorage

Throws:

ReplicationException - if there are errors accessing the storage service.

transitPeerSyncReplicationState

public void transitPeerSyncReplicationState(String peerId)
                                     throws ReplicationException

Description copied from interface: ReplicationPeerStorage

Overwrite the sync replication state with the new sync replication state which is set with the ReplicationPeerStorage.setPeerNewSyncReplicationState(String, SyncReplicationState) method above, and clear the new sync replication state.

Specified by:

transitPeerSyncReplicationState in interface ReplicationPeerStorage

Throws:

ReplicationException - if there are errors accessing the storage service.

getSyncReplicationState

private SyncReplicationState getSyncReplicationState(String peerId,
 String path)
                                              throws ReplicationException

Throws:

ReplicationException

getPeerNewSyncReplicationState

public SyncReplicationState getPeerNewSyncReplicationState(String peerId)
                                                    throws ReplicationException

Description copied from interface: ReplicationPeerStorage

Get the new sync replication state. Will return SyncReplicationState.NONE if we are not in a transition.

Specified by:

getPeerNewSyncReplicationState in interface ReplicationPeerStorage

Throws:

ReplicationException - if there are errors accessing the storage service.

getPeerSyncReplicationState

public SyncReplicationState getPeerSyncReplicationState(String peerId)
                                                 throws ReplicationException

Description copied from interface: ReplicationPeerStorage

Get the sync replication state.

Specified by:

getPeerSyncReplicationState in interface ReplicationPeerStorage

Throws:

ReplicationException - if there are errors accessing the storage service.