@InterfaceAudience.Private public abstract class ReplicationStateZKBase extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected Abortable |
abortable |
protected Configuration |
conf |
static byte[] |
DISABLED_ZNODE_BYTES |
static byte[] |
ENABLED_ZNODE_BYTES |
protected java.lang.String |
hfileRefsZNode
The name of the znode that contains queues of hfile references to be replicated
|
protected java.lang.String |
ourClusterKey
The cluster key of the local cluster
|
protected java.lang.String |
peerStateNodeName
The name of the znode that contains the replication status of a remote slave (i.e.
|
protected java.lang.String |
peersZNode
The name of the znode that contains a list of all remote slave (i.e.
|
protected java.lang.String |
queuesZNode
The name of the znode that contains all replication queues
|
protected boolean |
replicationForBulkLoadEnabled |
protected java.lang.String |
replicationZNode
The name of the base znode that contains all replication state.
|
protected ZooKeeperWatcher |
zookeeper |
static java.lang.String |
ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT |
static java.lang.String |
ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY |
Constructor and Description |
---|
ReplicationStateZKBase(ZooKeeperWatcher zookeeper,
Configuration conf,
Abortable abortable) |
Modifier and Type | Method and Description |
---|---|
java.util.List<java.lang.String> |
getListOfReplicators() |
protected boolean |
isPeerPath(java.lang.String path)
Determine if a ZK path points to a peer node.
|
protected boolean |
peerExists(java.lang.String id) |
protected static byte[] |
toByteArray(ZooKeeperProtos.ReplicationState.State state) |
protected final java.lang.String peerStateNodeName
protected final java.lang.String replicationZNode
protected final java.lang.String peersZNode
protected final java.lang.String queuesZNode
protected final java.lang.String hfileRefsZNode
protected final java.lang.String ourClusterKey
protected final ZooKeeperWatcher zookeeper
protected final Configuration conf
protected final Abortable abortable
protected final boolean replicationForBulkLoadEnabled
public static final byte[] ENABLED_ZNODE_BYTES
public static final byte[] DISABLED_ZNODE_BYTES
public static final java.lang.String ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY
public static final java.lang.String ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT
public ReplicationStateZKBase(ZooKeeperWatcher zookeeper, Configuration conf, Abortable abortable)
public java.util.List<java.lang.String> getListOfReplicators()
protected static byte[] toByteArray(ZooKeeperProtos.ReplicationState.State state)
state
- 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.protected boolean peerExists(java.lang.String id) throws KeeperException
KeeperException
protected boolean isPeerPath(java.lang.String path)
path
- path to be checked