ReplicationStateZKBase (Apache HBase 1.4.11 API)

java.lang.Object
- org.apache.hadoop.hbase.replication.ReplicationStateZKBase

Direct Known Subclasses:

ReplicationPeersZKImpl, ReplicationPeerZKImpl, ReplicationQueuesClientZKImpl, ReplicationQueuesZKImpl, ReplicationTrackerZKImpl, TableCFsUpdater
```
@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 ZooKeeperWatcher`	`zookeeper`
`static String`	`ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT`
`static String`	`ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY`

Constructor Summary

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

Method Summary

Methods
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.protobuf.generated.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
  - 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 ZooKeeperWatcher 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(ZooKeeperWatcher 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.protobuf.generated.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 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)
```

Class ReplicationStateZKBase

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

peerStateNodeName

replicationZNode

peersZNode

queuesZNode

hfileRefsZNode

ourClusterKey

tableCFsNodeName

zookeeper

conf

abortable

ENABLED_ZNODE_BYTES

DISABLED_ZNODE_BYTES

ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY

ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT

Constructor Detail

ReplicationStateZKBase

Method Detail

getListOfReplicatorsZK

toByteArray

peerExists

isPeerPath

getTableCFsNode

getPeerStateNode

getPeerNode