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

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

Modifier and Type	Class	Description
class	OfflineTableReplicationQueueStorage

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

Modifier and Type	Field	Description
private final ReplicationQueueStorage	ReplicationPeerManager.queueStorage

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

Modifier and Type	Method	Description
ReplicationQueueStorage	ReplicationPeerManager.getQueueStorage()

Methods in org.apache.hadoop.hbase.master.replication that return types with arguments of type ReplicationQueueStorage

Modifier and Type	Method	Description
private static Pair<ReplicationQueueStorage,ReplicationPeerManager.ReplicationQueueStorageInitializer>	ReplicationPeerManager.createReplicationQueueStorage(MasterServices services)

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

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

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

Modifier	Constructor	Description
(package private)	ReplicationPeerManager(org.apache.hadoop.fs.FileSystem fs, ZKWatcher zk, ReplicationPeerStorage peerStorage, ReplicationQueueStorage queueStorage, ConcurrentMap<String,ReplicationPeerDescription> peers, org.apache.hadoop.conf.Configuration conf, String clusterId, ReplicationPeerManager.ReplicationQueueStorageInitializer queueStorageInitializer)

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

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

Modifier and Type	Class	Description
class	TableReplicationQueueStorage	HBase table based replication queue storage.

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

Modifier and Type	Method	Description
static ReplicationQueueStorage	ReplicationStorageFactory.getReplicationQueueStorage(Connection conn, org.apache.hadoop.conf.Configuration conf)	Create a new ReplicationQueueStorage.
static ReplicationQueueStorage	ReplicationStorageFactory.getReplicationQueueStorage(Connection conn, org.apache.hadoop.conf.Configuration conf, TableName tableName)	Create a new ReplicationQueueStorage.

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	Description
private ReplicationQueueStorage	ReplicationHFileCleaner.rqs

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

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

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

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

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

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

Modifier and Type	Method	Description
private void	ReplicationSyncUp.addMissingReplicationQueues(ReplicationQueueStorage storage, Set<ServerName> regionServers, Set<String> peerIds)
private void	ReplicationSyncUp.addMissingReplicationQueues(ReplicationQueueStorage storage, ServerName regionServer, Set<String> peerIds)
void	ReplicationSource.init(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, ReplicationSourceManager manager, ReplicationQueueStorage queueStorage, ReplicationPeer replicationPeer, Server server, ReplicationQueueData queueData, UUID clusterId, WALFileLengthProvider walFileLengthProvider, MetricsSource metrics)	Instantiation method used by region servers
void	ReplicationSourceInterface.init(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, ReplicationSourceManager manager, ReplicationQueueStorage queueStorage, ReplicationPeer replicationPeer, Server server, ReplicationQueueData queueData, UUID clusterId, WALFileLengthProvider walFileLengthProvider, MetricsSource metrics)	Initializer for the source

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

Modifier	Constructor	Description
	RecoveredReplicationSourceShipper(org.apache.hadoop.conf.Configuration conf, String walGroupId, RecoveredReplicationSource source, ReplicationSourceWALReader walReader, ReplicationQueueStorage queueStorage, Runnable tryFinish)
	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, SyncReplicationPeerMappingManager syncReplicationPeerMappingManager, 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	Description
private final ReplicationQueueStorage	ReplicationChecker.queueStorage