ReplicationQueuesClientZKImpl (Apache HBase 1.2.12 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, ourClusterKey, peerStateNodeName, peersZNode, queuesZNode, replicationZNode, zookeeper

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>`	`getAllQueues(String serverName)` Get a list of all queues for the specified region server.
`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.
`void`	`init()` Initialize the replication queue client interface.

Methods inherited from class org.apache.hadoop.hbase.replication.ReplicationStateZKBase
getListOfReplicatorsZK, 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

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