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

Packages that use ReplicationQueueStorage

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

Uses of ReplicationQueueStorage in org.apache.hadoop.hbase.master.replication

Fields in org.apache.hadoop.hbase.master.replication declared as ReplicationQueueStorage

Modifier and Type	Field and Description
private ReplicationQueueStorage	ReplicationPeerManager.queueStorage

Methods in org.apache.hadoop.hbase.master.replication that return ReplicationQueueStorage

Modifier and Type	Method and Description
ReplicationQueueStorage	ReplicationPeerManager.getQueueStorage()

Methods in org.apache.hadoop.hbase.master.replication with parameters of type ReplicationQueueStorage

Modifier and Type	Method and Description
private void	UpdatePeerConfigProcedure.addToList(List<String> encodedRegionNames, String encodedRegionName, ReplicationQueueStorage queueStorage)
private void	ModifyPeerProcedure.addToMap(Map<String,Long> lastSeqIds, String encodedRegionName, long barrier, ReplicationQueueStorage queueStorage)

Constructors in org.apache.hadoop.hbase.master.replication with parameters of type ReplicationQueueStorage

Constructor and Description
ReplicationPeerManager(ReplicationPeerStorage peerStorage, ReplicationQueueStorage queueStorage, ConcurrentMap<String,ReplicationPeerDescription> peers, org.apache.hadoop.conf.Configuration conf, String clusterId)

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

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

Modifier and Type	Class and Description
(package private) class	ZKReplicationQueueStorage ZK based replication queue storage.

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

Modifier and Type	Method and Description
static ReplicationQueueStorage	ReplicationStorageFactory.getReplicationQueueStorage(ZKWatcher zk, org.apache.hadoop.conf.Configuration conf) Create a new ReplicationQueueStorage.

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

Modifier and Type	Method and Description
static void	ReplicationUtils.removeAllQueues(ReplicationQueueStorage queueStorage, String peerId)

Uses of ReplicationQueueStorage in org.apache.hadoop.hbase.replication.master

Fields in org.apache.hadoop.hbase.replication.master declared as ReplicationQueueStorage

Modifier and Type	Field and Description
private ReplicationQueueStorage	ReplicationLogCleaner.queueStorage
private ReplicationQueueStorage	ReplicationHFileCleaner.rqs

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

Classes in org.apache.hadoop.hbase.replication.regionserver that implement ReplicationQueueStorage

Modifier and Type	Class and Description
(package private) class	NoopReplicationQueueStorage Noop queue storage -- does nothing.

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

Modifier and Type	Field and Description
private ReplicationQueueStorage	ReplicationSourceManager.queueStorage Storage for queues that need persistance; e.g.
private ReplicationQueueStorage	Replication.queueStorage
protected ReplicationQueueStorage	ReplicationSource.queueStorage
private ReplicationQueueStorage	RecoveredReplicationSourceShipper.replicationQueues
private ReplicationQueueStorage	SerialReplicationChecker.storage

Methods in org.apache.hadoop.hbase.replication.regionserver that return ReplicationQueueStorage

Modifier and Type	Method and Description
(package private) ReplicationQueueStorage	ReplicationSourceManager.getQueueStorage()
ReplicationQueueStorage	ReplicationSourceInterface.getReplicationQueueStorage() Returns The instance of queueStorage used by this ReplicationSource.
ReplicationQueueStorage	ReplicationSource.getReplicationQueueStorage()

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

Modifier and Type	Method and Description
private String	DumpReplicationQueues.formatQueue(ServerName regionserver, ReplicationQueueStorage queueStorage, ReplicationQueueInfo queueInfo, String queueId, List<String> wals, boolean isDeleted, boolean hdfs)
void	RecoveredReplicationSource.init(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, ReplicationSourceManager manager, ReplicationQueueStorage queueStorage, ReplicationPeer replicationPeer, Server server, String peerClusterZnode, UUID clusterId, WALFileLengthProvider walFileLengthProvider, MetricsSource metrics)
void	ReplicationSourceInterface.init(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, ReplicationSourceManager manager, ReplicationQueueStorage queueStorage, ReplicationPeer replicationPeer, Server server, String queueId, UUID clusterId, 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, ReplicationQueueStorage queueStorage, ReplicationPeer replicationPeer, Server server, String queueId, UUID clusterId, WALFileLengthProvider walFileLengthProvider, MetricsSource metrics) Instantiation method used by region servers

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

Constructor and Description
RecoveredReplicationSourceShipper(org.apache.hadoop.conf.Configuration conf, String walGroupId, ReplicationSourceLogQueue logQueue, RecoveredReplicationSource source, ReplicationQueueStorage queueStorage)
ReplicationSourceManager(ReplicationQueueStorage queueStorage, ReplicationPeers replicationPeers, 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, WALFactory walFactory, MetricsReplicationGlobalSourceSource globalMetrics) Creates a replication manager and sets the watch on all the other registered region servers

Uses of ReplicationQueueStorage in org.apache.hadoop.hbase.util.hbck

Fields in org.apache.hadoop.hbase.util.hbck declared as ReplicationQueueStorage

Modifier and Type	Field and Description
private ReplicationQueueStorage	ReplicationChecker.queueStorage