TableBasedReplicationQueuesClientImpl (Apache HBase 3.0.0-SNAPSHOT API)

java.lang.Object
-
- org.apache.hadoop.hbase.replication.ReplicationTableBase
- -
  - org.apache.hadoop.hbase.replication.TableBasedReplicationQueuesClientImpl
  -
-

-
-
All Implemented Interfaces:
-
ReplicationQueuesClient
-
-
-
-
```
@InterfaceAudience.Private
-public class TableBasedReplicationQueuesClientImpl
-extends ReplicationTableBase
-implements ReplicationQueuesClient
```
-
Implements the ReplicationQueuesClient interface on top of the Replication Table. It utilizes - the ReplicationTableBase to access the Replication Table.
-

- -

- - -
Field Summary
-
- - - -
  Fields inherited from class org.apache.hadoop.hbase.replication.ReplicationTableBase
  -abortable, CF_QUEUE, COL_QUEUE_OWNER, COL_QUEUE_OWNER_HISTORY, conf, QUEUE_HISTORY_DELIMITER, REPLICATION_TABLE_NAME, ROW_KEY_DELIMITER
-

- -

Constructor Summary

- - - - - - - - - - - -

Constructors
Constructor and Description
`TableBasedReplicationQueuesClientImpl(org.apache.hadoop.conf.Configuration conf, - Abortable abortable)`
`TableBasedReplicationQueuesClientImpl(ReplicationQueuesClientArguments args)`

- -

- - -

Method Summary

- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -

All Methods Instance Methods Concrete 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. -
`Set<String>`	`getAllWALs()` - Load all wals in all replication queues from ZK. -
`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. -
`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.ReplicationTableBase
-buildClaimedQueueHistory, buildQueueRowKey, getInitializationStatus, getLogsInQueue, getOrBlockOnReplicationTable, getQueuesBelongingToServer, getRawQueueIdFromRowKey, queueIdToRowKey, readWALsFromResult

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

- -
- - - -
  Constructor Detail
  - - - -
  - -
    TableBasedReplicationQueuesClientImpl
    -
```
public TableBasedReplicationQueuesClientImpl(ReplicationQueuesClientArguments args)
-                                      throws IOException
```
    -
    -
    Throws:
    -
    IOException
    -
    -
  - - - -
  - -
    TableBasedReplicationQueuesClientImpl
    -
```
public TableBasedReplicationQueuesClientImpl(org.apache.hadoop.conf.Configuration conf,
-                                             Abortable abortable)
-                                      throws IOException
```
    -
    -
    Throws:
    -
    IOException
    -
    -
  -
- -
- - - -
  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()
```
    -
    Description copied from class: ReplicationTableBase
    -
    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
    -
    Overrides:
    -
    getListOfReplicators in class ReplicationTableBase
    -
    Returns:
    -
    a list of server names
    -
    -
  - - - -
  - -
    getLogsInQueue
    -
```
public List<String> getLogsInQueue(String serverName,
-                                   String queueId)
```
    -
    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
    -
    Overrides:
    -
    getLogsInQueue in class ReplicationTableBase
    -
    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
    -
    -
  - - - -
  - -
    getAllQueues
    -
```
public List<String> getAllQueues(String serverName)
```
    -
    Description copied from interface: ReplicationQueuesClient
    -
    Get a list of all queues for the specified region server.
    -
    -
    Specified by:
    -
    getAllQueues in interface ReplicationQueuesClient
    -
    Overrides:
    -
    getAllQueues in class ReplicationTableBase
    -
    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.
    -
    -
  - - - -
  - -
    getAllWALs
    -
```
public Set<String> getAllWALs()
```
    -
    Description copied from interface: ReplicationQueuesClient
    -
    Load all wals in all replication queues from ZK. This method guarantees to return a - snapshot which contains all WALs in the zookeeper at the start of this call even there - is concurrent queue failover. However, some newly created WALs during the call may - not be included.
    -
    -
    Specified by:
    -
    getAllWALs in interface ReplicationQueuesClient
    -
    -
  - - - -
  - -
    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 TableBasedReplicationQueuesClientImpl

Field Summary

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

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

Constructor Detail

TableBasedReplicationQueuesClientImpl

TableBasedReplicationQueuesClientImpl

Method Detail

init

getListOfReplicators

getLogsInQueue

getAllQueues

getAllWALs

getHFileRefsNodeChangeVersion

getAllPeersFromHFileRefsQueue

getReplicableHFiles