ReplicationQueuesClientZKImpl (Apache HBase 1.4.11 API)

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

All Implemented Interfaces:: ReplicationQueuesClient

@InterfaceAudience.Private
public class ReplicationQueuesClientZKImpl
extends ReplicationStateZKBase
implements ReplicationQueuesClient

Field Summary
- Fields inherited from class org.apache.hadoop.hbase.replication.ReplicationStateZKBase
  abortable, conf, DISABLED_ZNODE_BYTES, ENABLED_ZNODE_BYTES, hfileRefsZNode, ourClusterKey, peerStateNodeName, peersZNode, queuesZNode, replicationZNode, tableCFsNodeName, zookeeper, ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT, ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY

Constructor Summary

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

Method Summary

Methods
Modifier and Type	Method and Description
`List<String>`	`getAllPeersFromHFileRefsQueue()` Get list of all peers from hfile reference queue.
`List<String>`	`getAllQueues(String serverName)` Get a list of all queues for the specified region server.
`int`	`getHFileRefsNodeChangeVersion()` Get the change version number of replication hfile references node.
`List<String>`	`getListOfReplicators()` Get a list of all region servers that have outstanding replication queues.
`List<String>`	`getLogsInQueue(String serverName, String queueId)` Get a list of all WALs in the given queue on the given region server.
`int`	`getQueuesZNodeCversion()` Get the cversion of replication rs node.
`List<String>`	`getReplicableHFiles(String peerId)` Get a list of all hfile references in the given peer.
`void`	`init()` Initialize the replication queue client interface.

Methods inherited from class org.apache.hadoop.hbase.replication.ReplicationStateZKBase
getListOfReplicatorsZK, getPeerNode, getPeerStateNode, getTableCFsNode, isPeerPath, peerExists, toByteArray

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - ReplicationQueuesClientZKImpl
```
public ReplicationQueuesClientZKImpl(ZooKeeperWatcher zk,
                             org.apache.hadoop.conf.Configuration conf,
                             Abortable abortable)
```
- Method Detail
  - init
```
public void init()
          throws ReplicationException
```
    Description copied from interface: ReplicationQueuesClient
    
    Initialize the replication queue client interface.
    
    Specified by:
    
    init in interface ReplicationQueuesClient
    
    Throws:
    
    ReplicationException
  - getListOfReplicators
```
public List<String> getListOfReplicators()
                                  throws org.apache.zookeeper.KeeperException
```
    Description copied from interface: ReplicationQueuesClient
    
    Get a list of all region servers that have outstanding replication queues. These servers could be alive, dead or from a previous run of the cluster.
    
    Specified by:
    
    getListOfReplicators in interface ReplicationQueuesClient
    
    Returns:
    a list of server names
    
    Throws:
    
    org.apache.zookeeper.KeeperException - zookeeper exception
  - getLogsInQueue
```
public List<String> getLogsInQueue(String serverName,
                          String queueId)
                            throws org.apache.zookeeper.KeeperException
```
    Description copied from interface: ReplicationQueuesClient
    
    Get a list of all WALs in the given queue on the given region server.
    
    Specified by:
    
    getLogsInQueue in interface ReplicationQueuesClient
    
    Parameters:
    serverName - the server name of the region server that owns the queue
    queueId - a String that identifies the queue
    
    Returns:
    a list of WALs, null if this region server is dead and has no outstanding queues
    
    Throws:
    
    org.apache.zookeeper.KeeperException - zookeeper exception
  - getAllQueues
```
public List<String> getAllQueues(String serverName)
                          throws org.apache.zookeeper.KeeperException
```
    Description copied from interface: ReplicationQueuesClient
    
    Get a list of all queues for the specified region server.
    
    Specified by:
    
    getAllQueues in interface ReplicationQueuesClient
    
    Parameters:
    serverName - the server name of the region server that owns the set of queues
    
    Returns:
    a list of queueIds, null if this region server is not a replicator.
    
    Throws:
    
    org.apache.zookeeper.KeeperException
  - getQueuesZNodeCversion
```
public int getQueuesZNodeCversion()
                           throws org.apache.zookeeper.KeeperException
```
    Description copied from interface: ReplicationQueuesClient
    
    Get the cversion of replication rs node. This can be used as optimistic locking to get a consistent snapshot of the replication queues.
    
    Specified by:
    
    getQueuesZNodeCversion in interface ReplicationQueuesClient
    
    Returns:
    cversion of replication rs node
    
    Throws:
    
    org.apache.zookeeper.KeeperException
  - getHFileRefsNodeChangeVersion
```
public int getHFileRefsNodeChangeVersion()
                                  throws org.apache.zookeeper.KeeperException
```
    Description copied from interface: ReplicationQueuesClient
    
    Get the change version number of replication hfile references node. This can be used as optimistic locking to get a consistent snapshot of the replication queues of hfile references.
    
    Specified by:
    
    getHFileRefsNodeChangeVersion in interface ReplicationQueuesClient
    
    Returns:
    change version number of hfile references node
    
    Throws:
    
    org.apache.zookeeper.KeeperException
  - getAllPeersFromHFileRefsQueue
```
public List<String> getAllPeersFromHFileRefsQueue()
                                           throws org.apache.zookeeper.KeeperException
```
    Description copied from interface: ReplicationQueuesClient
    
    Get list of all peers from hfile reference queue.
    
    Specified by:
    
    getAllPeersFromHFileRefsQueue in interface ReplicationQueuesClient
    
    Returns:
    a list of peer ids
    
    Throws:
    
    org.apache.zookeeper.KeeperException - zookeeper exception
  - getReplicableHFiles
```
public List<String> getReplicableHFiles(String peerId)
                                 throws org.apache.zookeeper.KeeperException
```
    Description copied from interface: ReplicationQueuesClient
    
    Get a list of all hfile references in the given peer.
    
    Specified by:
    
    getReplicableHFiles in interface ReplicationQueuesClient
    
    Parameters:
    peerId - a String that identifies the peer
    
    Returns:
    a list of hfile references, null if not found any
    
    Throws:
    
    org.apache.zookeeper.KeeperException - zookeeper exception

Class ReplicationQueuesClientZKImpl

Field Summary

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

Constructor Summary

Method Summary

Methods inherited from class org.apache.hadoop.hbase.replication.ReplicationStateZKBase

Methods inherited from class java.lang.Object

Constructor Detail

ReplicationQueuesClientZKImpl

Method Detail

init

getListOfReplicators

getLogsInQueue

getAllQueues

getQueuesZNodeCversion

getHFileRefsNodeChangeVersion

getAllPeersFromHFileRefsQueue

getReplicableHFiles