Uses of Interface
org.apache.hadoop.hbase.replication.ReplicationQueues

Packages that use ReplicationQueues

Package	Description
org.apache.hadoop.hbase.replication	Multi Cluster Replication
org.apache.hadoop.hbase.replication.regionserver

Uses of ReplicationQueues in org.apache.hadoop.hbase.replication

Classes in org.apache.hadoop.hbase.replication that implement ReplicationQueues

Modifier and Type	Class and Description
class	ReplicationQueuesZKImpl This class provides an implementation of the interface using ZooKeeper.

Methods in org.apache.hadoop.hbase.replication that return ReplicationQueues

Modifier and Type	Method and Description
static ReplicationQueues	ReplicationFactory.getReplicationQueues(ReplicationQueuesArguments args)

Uses of ReplicationQueues in org.apache.hadoop.hbase.replication.regionserver

Fields in org.apache.hadoop.hbase.replication.regionserver declared as ReplicationQueues

Modifier and Type	Field and Description
private ReplicationQueues	RecoveredReplicationSourceShipper.replicationQueues
private ReplicationQueues	ReplicationSourceManager.replicationQueues
private ReplicationQueues	Replication.replicationQueues
protected ReplicationQueues	ReplicationSource.replicationQueues
private ReplicationQueues	ReplicationSourceManager.NodeFailoverWorker.rq

Methods in org.apache.hadoop.hbase.replication.regionserver with parameters of type ReplicationQueues

Modifier and Type	Method and Description
private String	DumpReplicationQueues.formatQueue(String regionserver, ReplicationQueues replicationQueues, ReplicationQueueInfo queueInfo, String queueId, List<String> wals, boolean isDeleted, boolean hdfs)
private ReplicationSourceInterface	ReplicationSourceManager.getReplicationSource(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, ReplicationSourceManager manager, ReplicationQueues replicationQueues, ReplicationPeers replicationPeers, Server server, String peerId, UUID clusterId, ReplicationPeerConfig peerConfig, ReplicationPeer replicationPeer, WALFileLengthProvider walFileLengthProvider) Factory method to create a replication source
void	RecoveredReplicationSource.init(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, ReplicationSourceManager manager, ReplicationQueues replicationQueues, ReplicationPeers replicationPeers, Server server, String peerClusterZnode, UUID clusterId, ReplicationEndpoint replicationEndpoint, WALFileLengthProvider walFileLengthProvider, MetricsSource metrics)
void	ReplicationSourceInterface.init(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, ReplicationSourceManager manager, ReplicationQueues replicationQueues, ReplicationPeers replicationPeers, Server server, String peerClusterZnode, UUID clusterId, ReplicationEndpoint replicationEndpoint, WALFileLengthProvider walFileLengthProvider, MetricsSource metrics) Initializer for the source
void	ReplicationSource.init(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, ReplicationSourceManager manager, ReplicationQueues replicationQueues, ReplicationPeers replicationPeers, Server server, String peerClusterZnode, UUID clusterId, ReplicationEndpoint replicationEndpoint, WALFileLengthProvider walFileLengthProvider, MetricsSource metrics) Instantiation method used by region servers

Constructors in org.apache.hadoop.hbase.replication.regionserver with parameters of type ReplicationQueues

Constructor and Description
NodeFailoverWorker(String rsZnode, ReplicationQueues replicationQueues, ReplicationPeers replicationPeers, UUID clusterId)
RecoveredReplicationSourceShipper(org.apache.hadoop.conf.Configuration conf, String walGroupId, PriorityBlockingQueue<org.apache.hadoop.fs.Path> queue, RecoveredReplicationSource source, ReplicationQueues replicationQueues)
ReplicationSourceManager(ReplicationQueues replicationQueues, ReplicationPeers replicationPeers, ReplicationTracker replicationTracker, org.apache.hadoop.conf.Configuration conf, Server server, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path logDir, org.apache.hadoop.fs.Path oldLogDir, UUID clusterId, WALFileLengthProvider walFileLengthProvider) Creates a replication manager and sets the watch on all the other registered region servers