org.apache.hadoop.hbase.replication

类 ReplicationQueuesClientZKImpl

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationStateZKBase

org.apache.hadoop.hbase.replication.ReplicationQueuesClientZKImpl

所有已实现的接口:

ReplicationQueuesClient

@InterfaceAudience.Private
public class ReplicationQueuesClientZKImpl
extends ReplicationStateZKBase
implements ReplicationQueuesClient

字段概要

从类继承的字段 org.apache.hadoop.hbase.replication.ReplicationStateZKBase

abortable, conf, DISABLED_ZNODE_BYTES, ENABLED_ZNODE_BYTES, ourClusterKey, peerStateNodeName, peersZNode, queuesZNode, replicationZNode, zookeeper

构造器概要

构造器

构造器和说明
ReplicationQueuesClientZKImpl(ZooKeeperWatcher zk, org.apache.hadoop.conf.Configuration conf, Abortable abortable)

方法概要

方法

限定符和类型	方法和说明
List<String>	getAllQueues(String serverName) Get a list of all queues for the specified region server.
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.

从类继承的方法 org.apache.hadoop.hbase.replication.ReplicationStateZKBase

getListOfReplicators, isPeerPath, peerExists, toByteArray

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.apache.hadoop.hbase.replication.ReplicationQueuesClient

getListOfReplicators

构造器详细资料

ReplicationQueuesClientZKImpl

public ReplicationQueuesClientZKImpl(ZooKeeperWatcher zk,
                             org.apache.hadoop.conf.Configuration conf,
                             Abortable abortable)

方法详细资料

init

public void init()
          throws ReplicationException

从接口复制的说明: ReplicationQueuesClient

Initialize the replication queue client interface.

指定者:

init 在接口中 ReplicationQueuesClient

抛出:

ReplicationException

getLogsInQueue

public List<String> getLogsInQueue(String serverName,
                          String queueId)
                            throws org.apache.zookeeper.KeeperException

从接口复制的说明: ReplicationQueuesClient

Get a list of all WALs in the given queue on the given region server.

指定者:

getLogsInQueue 在接口中 ReplicationQueuesClient

参数:

serverName - the server name of the region server that owns the queue

queueId - a String that identifies the queue

返回:

a list of WALs, null if this region server is dead and has no outstanding queues

抛出:

org.apache.zookeeper.KeeperException - zookeeper exception

getAllQueues

public List<String> getAllQueues(String serverName)
                          throws org.apache.zookeeper.KeeperException

从接口复制的说明: ReplicationQueuesClient

Get a list of all queues for the specified region server.

指定者:

getAllQueues 在接口中 ReplicationQueuesClient

参数:

serverName - the server name of the region server that owns the set of queues

返回:

a list of queueIds, null if this region server is not a replicator.

抛出:

org.apache.zookeeper.KeeperException

getQueuesZNodeCversion

public int getQueuesZNodeCversion()
                           throws org.apache.zookeeper.KeeperException

从接口复制的说明: ReplicationQueuesClient

Get the cversion of replication rs node. This can be used as optimistic locking to get a consistent snapshot of the replication queues.

指定者:

getQueuesZNodeCversion 在接口中 ReplicationQueuesClient

返回:

cversion of replication rs node

抛出:

org.apache.zookeeper.KeeperException