Uses of Class
org.apache.hadoop.hbase.replication.ReplicationQueueId

Packages that use ReplicationQueueId

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

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

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

Modifier and Type	Field	Description
private ReplicationQueueId	ClaimReplicationQueueRemoteProcedure.queueId

Fields in org.apache.hadoop.hbase.master.replication with type parameters of type ReplicationQueueId

Modifier and Type	Field	Description
private final Map<ReplicationQueueId,Map<String,ReplicationGroupOffset>>	OfflineTableReplicationQueueStorage.offsets

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

Modifier and Type	Method	Description
List<ReplicationQueueId>	OfflineTableReplicationQueueStorage.listAllQueueIds(String peerId)
List<ReplicationQueueId>	OfflineTableReplicationQueueStorage.listAllQueueIds(String peerId, ServerName serverName)
List<ReplicationQueueId>	OfflineTableReplicationQueueStorage.listAllQueueIds(ServerName serverName)

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

Modifier and Type	Method	Description
Map<String,ReplicationGroupOffset>	OfflineTableReplicationQueueStorage.claimQueue(ReplicationQueueId queueId, ServerName targetServerName)
Map<String,ReplicationGroupOffset>	OfflineTableReplicationQueueStorage.getOffsets(ReplicationQueueId queueId)
void	OfflineTableReplicationQueueStorage.removeQueue(ReplicationQueueId queueId)
void	OfflineTableReplicationQueueStorage.setOffset(ReplicationQueueId queueId, String walGroup, ReplicationGroupOffset offset, Map<String,Long> lastSeqIds)

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

Modifier	Constructor	Description
	ClaimReplicationQueueRemoteProcedure(ReplicationQueueId queueId, ServerName targetServer)

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

Fields in org.apache.hadoop.hbase.replication declared as ReplicationQueueId

Modifier and Type	Field	Description
private final ReplicationQueueId	ReplicationQueueData.id
private final ReplicationQueueId	ZKReplicationQueueStorageForMigration.ZkReplicationQueueData.queueId

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

Modifier and Type	Method	Description
ReplicationQueueId	ReplicationQueueId.claim(ServerName targetServerName)
ReplicationQueueId	ReplicationQueueData.getId()
ReplicationQueueId	ZKReplicationQueueStorageForMigration.ZkReplicationQueueData.getQueueId()
static ReplicationQueueId	ReplicationQueueId.parse(String str)

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

Modifier and Type	Method	Description
List<ReplicationQueueId>	ReplicationQueueStorage.listAllQueueIds(String peerId)	Get a list of all queues for the specific peer.
List<ReplicationQueueId>	ReplicationQueueStorage.listAllQueueIds(String peerId, ServerName serverName)	Get a list of all queues for the specific region server and the specific peer
List<ReplicationQueueId>	ReplicationQueueStorage.listAllQueueIds(ServerName serverName)	Get a list of all queues for the specific region server.
List<ReplicationQueueId>	TableReplicationQueueStorage.listAllQueueIds(String peerId)
List<ReplicationQueueId>	TableReplicationQueueStorage.listAllQueueIds(String peerId, ServerName serverName)
List<ReplicationQueueId>	TableReplicationQueueStorage.listAllQueueIds(ServerName serverName)

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

Modifier and Type	Method	Description
Map<String,ReplicationGroupOffset>	ReplicationQueueStorage.claimQueue(ReplicationQueueId queueId, ServerName targetServerName)	Change ownership for the queue identified by queueId and belongs to a dead region server.
Map<String,ReplicationGroupOffset>	TableReplicationQueueStorage.claimQueue(ReplicationQueueId queueId, ServerName targetServerName)
Map<String,ReplicationGroupOffset>	ReplicationQueueStorage.getOffsets(ReplicationQueueId queueId)	Get the current offset of all the WAL groups for a queue
Map<String,ReplicationGroupOffset>	TableReplicationQueueStorage.getOffsets(ReplicationQueueId queueId)
private Map<String,ReplicationGroupOffset>	TableReplicationQueueStorage.getOffsets0(Table table, ReplicationQueueId queueId)
void	ReplicationQueueStorage.removeQueue(ReplicationQueueId queueId)	Remove a replication queue
void	TableReplicationQueueStorage.removeQueue(ReplicationQueueId queueId)
void	ReplicationQueueStorage.setOffset(ReplicationQueueId queueId, String walGroup, ReplicationGroupOffset offset, Map<String,Long> lastSeqIds)	Set the current offset for a specific WAL group in a given queue.
void	TableReplicationQueueStorage.setOffset(ReplicationQueueId queueId, String walGroup, ReplicationGroupOffset offset, Map<String,Long> lastSeqIds)

Method parameters in org.apache.hadoop.hbase.replication with type arguments of type ReplicationQueueId

Modifier and Type	Method	Description
private void	TableReplicationQueueStorage.listAllQueueIds(Table table, String peerId, ServerName serverName, List<ReplicationQueueId> queueIds)
private void	TableReplicationQueueStorage.listAllQueueIds(Table table, Scan scan, List<ReplicationQueueId> queueIds)

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

Modifier	Constructor	Description
	ReplicationQueueData(ReplicationQueueId id, org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<String,ReplicationGroupOffset> offsets)
	ZkReplicationQueueData(ReplicationQueueId queueId, Map<String,Long> walOffsets)

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

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

Modifier and Type	Field	Description
private ReplicationQueueId	ClaimReplicationQueueCallable.queueId
protected ReplicationQueueId	ReplicationSource.queueId

Fields in org.apache.hadoop.hbase.replication.regionserver with type parameters of type ReplicationQueueId

Modifier and Type	Field	Description
private final ConcurrentMap<ReplicationQueueId,Map<String,NavigableSet<String>>>	ReplicationSourceManager.walsById
private final ConcurrentMap<ReplicationQueueId,Map<String,NavigableSet<org.apache.hadoop.fs.Path>>>	ReplicationSourceManager.walsByIdRecoveredQueues

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

Modifier and Type	Method	Description
ReplicationQueueId	ReplicationSource.getQueueId()
ReplicationQueueId	ReplicationSourceInterface.getQueueId()	Get the queue id that the source is replicating to

Methods in org.apache.hadoop.hbase.replication.regionserver that return types with arguments of type ReplicationQueueId

Modifier and Type	Method	Description
Map<ReplicationQueueId,Map<String,NavigableSet<String>>>	ReplicationSourceManager.getWALs()	Get a copy of the wals of the normal sources on this rs

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

Modifier and Type	Method	Description
private void	ReplicationSourceManager.addRecoveredSource(ReplicationSourceInterface src, ReplicationPeerImpl oldPeer, ReplicationQueueId claimedQueueId, PriorityQueue<org.apache.hadoop.fs.Path> walFiles)
(package private) void	ReplicationSourceManager.claimQueue(ReplicationQueueId queueId)
(package private) void	ReplicationSourceManager.claimQueue(ReplicationQueueId queueId, boolean syncUp)	Claim a replication queue.
void	PeerProcedureHandler.claimReplicationQueue(ReplicationQueueId queueId)
void	PeerProcedureHandlerImpl.claimReplicationQueue(ReplicationQueueId queueId)
(package private) static ReplicationSourceInterface	ReplicationSourceFactory.create(org.apache.hadoop.conf.Configuration conf, ReplicationQueueId queueId)
private ReplicationSourceInterface	ReplicationSourceManager.createRefreshedSource(ReplicationQueueId queueId, ReplicationPeer peer)
private void	ReplicationSourceManager.deleteQueue(ReplicationQueueId queueId)	Delete a complete queue of wals associated with a replication source
private String	DumpReplicationQueues.formatQueue(ServerName regionServer, Map<String,ReplicationGroupOffset> offsets, List<String> wals, ReplicationQueueId queueId, boolean isDeleted, boolean hdfs)

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

Fields in org.apache.hadoop.hbase.util.hbck with type parameters of type ReplicationQueueId

Modifier and Type	Field	Description
private Map<ServerName,List<ReplicationQueueId>>	ReplicationChecker.undeletedQueueIds

Methods in org.apache.hadoop.hbase.util.hbck that return types with arguments of type ReplicationQueueId

Modifier and Type	Method	Description
private Map<ServerName,List<ReplicationQueueId>>	ReplicationChecker.getUnDeletedQueues()