org.apache.hadoop.hbase.replication

Class ReplicationStateZKBase

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationStateZKBase

Direct Known Subclasses:

ReplicationPeersZKImpl, ReplicationQueuesClientZKImpl, ReplicationQueuesZKImpl, ReplicationTrackerZKImpl

@InterfaceAudience.Private
public abstract class ReplicationStateZKBase
extends Object

This is a base class for maintaining replication state in zookeeper.

Field Summary

Fields

Modifier and Type	Field and Description
protected Abortable	abortable
protected Configuration	conf
static byte[]	DISABLED_ZNODE_BYTES
static byte[]	ENABLED_ZNODE_BYTES
protected String	ourClusterKey The cluster key of the local cluster
protected String	peerStateNodeName The name of the znode that contains the replication status of a remote slave (i.e.
protected String	peersZNode The name of the znode that contains a list of all remote slave (i.e.
protected String	queuesZNode The name of the znode that contains all replication queues
protected String	replicationZNode The name of the base znode that contains all replication state.
protected ZooKeeperWatcher	zookeeper

Constructor Summary

Constructors

Constructor and Description
ReplicationStateZKBase(ZooKeeperWatcher zookeeper, Configuration conf, Abortable abortable)

Method Summary

Modifier and Type	Method and Description
List<String>	getListOfReplicators()
protected boolean	isPeerPath(String path) Determine if a ZK path points to a peer node.
protected boolean	peerExists(String id)
protected static byte[]	toByteArray(ZooKeeperProtos.ReplicationState.State state)

Methods inherited from class java.lang.Object

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

Field Detail

peerStateNodeName

protected final String peerStateNodeName

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

replicationZNode

protected final String replicationZNode

The name of the base znode that contains all replication state.

peersZNode

protected final String peersZNode

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

queuesZNode

protected final String queuesZNode

The name of the znode that contains all replication queues

ourClusterKey

protected final String ourClusterKey

The cluster key of the local cluster

zookeeper

protected final ZooKeeperWatcher zookeeper

conf

protected final Configuration conf

abortable

protected final Abortable abortable

ENABLED_ZNODE_BYTES

public static final byte[] ENABLED_ZNODE_BYTES

DISABLED_ZNODE_BYTES

public static final byte[] DISABLED_ZNODE_BYTES

Constructor Detail

ReplicationStateZKBase

public ReplicationStateZKBase(ZooKeeperWatcher zookeeper,
                              Configuration conf,
                              Abortable abortable)

Method Detail

getListOfReplicators

public List<String> getListOfReplicators()

toByteArray

protected static byte[] toByteArray(ZooKeeperProtos.ReplicationState.State state)

Parameters:

state -

Returns:

Serialized protobuf of state with pb magic prefix prepended suitable for use as content of a peer-state znode under a peer cluster id as in /hbase/replication/peers/PEER_ID/peer-state.

peerExists

protected boolean peerExists(String id)
                      throws KeeperException

Throws:

KeeperException

isPeerPath

protected boolean isPeerPath(String path)

Determine if a ZK path points to a peer node.

Parameters:

path - path to be checked

Returns:

true if the path points to a peer node, otherwise false