org.apache.hadoop.hbase.replication

Class ReplicationStateZKBase

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationStateZKBase

Direct Known Subclasses:

ReplicationPeerConfigUpgrader, ReplicationPeersZKImpl, ReplicationPeerZKImpl, ReplicationQueuesClientZKImpl, ReplicationQueuesZKImpl, ReplicationTrackerZKImpl, ReplicationZKNodeCleaner.ReplicationQueueDeletor

@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 org.apache.hadoop.conf.Configuration	conf
static byte[]	DISABLED_ZNODE_BYTES
static byte[]	ENABLED_ZNODE_BYTES
protected String	hfileRefsZNode The name of the znode that contains queues of hfile references to be replicated
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 String	tableCFsNodeName The name of the znode that contains tableCFs
protected ZKWatcher	zookeeper
static String	ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT
static String	ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY

Constructor Summary

Constructors

Constructor and Description
ReplicationStateZKBase(ZKWatcher zookeeper, org.apache.hadoop.conf.Configuration conf, Abortable abortable)

Method Summary

Modifier and Type	Method and Description
protected List<String>	getListOfReplicatorsZK() Subclasses that use ZK explicitly can just call this directly while classes that are trying to hide internal details of storage can wrap the KeeperException into a ReplicationException or something else.
protected String	getPeerNode(String id)
protected String	getPeerStateNode(String id)
protected String	getTableCFsNode(String id)
protected boolean	isPeerPath(String path) Determine if a ZK path points to a peer node.
protected boolean	peerExists(String id)
protected static byte[]	toByteArray(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.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

hfileRefsZNode

protected final String hfileRefsZNode

The name of the znode that contains queues of hfile references to be replicated

ourClusterKey

protected final String ourClusterKey

The cluster key of the local cluster

tableCFsNodeName

protected final String tableCFsNodeName

The name of the znode that contains tableCFs

zookeeper

protected final ZKWatcher zookeeper

conf

protected final org.apache.hadoop.conf.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

ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY

public static final String ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY

See Also:

Constant Field Values

ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT

public static final String ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT

See Also:

Constant Field Values

Constructor Detail

ReplicationStateZKBase

public ReplicationStateZKBase(ZKWatcher zookeeper,
                              org.apache.hadoop.conf.Configuration conf,
                              Abortable abortable)

Method Detail

getListOfReplicatorsZK

protected List<String> getListOfReplicatorsZK()
                                       throws org.apache.zookeeper.KeeperException

Subclasses that use ZK explicitly can just call this directly while classes that are trying to hide internal details of storage can wrap the KeeperException into a ReplicationException or something else.

Throws:

org.apache.zookeeper.KeeperException

toByteArray

protected static byte[] toByteArray(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.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 org.apache.zookeeper.KeeperException

Throws:

org.apache.zookeeper.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

getTableCFsNode

protected String getTableCFsNode(String id)

getPeerStateNode

protected String getPeerStateNode(String id)

getPeerNode

protected String getPeerNode(String id)