Uses of Interface
org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

Packages that use ReplicationSourceInterface

Package	Description
org.apache.hadoop.hbase.replication.regionserver

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

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

Modifier and Type	Class	Description
(package private) class	CatalogReplicationSource	ReplicationSource that reads catalog WAL files -- e.g.
class	RecoveredReplicationSource	Class that handles the recovered source of a replication stream, which is transfered from another dead region server.
class	ReplicationSource	Class that handles the source of a replication stream.

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

Modifier and Type	Field	Description
(package private) AtomicReference<ReplicationSourceInterface>	ReplicationSourceManager.catalogReplicationSource	A special ReplicationSource for hbase:meta Region Read Replicas.
private final List<ReplicationSourceInterface>	ReplicationSourceManager.oldsources
private final ConcurrentMap<String,ReplicationSourceInterface>	ReplicationSourceManager.sources

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

Modifier and Type	Method	Description
ReplicationSourceInterface	ReplicationSourceManager.addCatalogReplicationSource(RegionInfo regionInfo)	Add an hbase:meta Catalog replication source.
(package private) ReplicationSourceInterface	ReplicationSourceManager.addSource(String peerId)	Add a normal source for the given peer on this region server.
(package private) static ReplicationSourceInterface	ReplicationSourceFactory.create(org.apache.hadoop.conf.Configuration conf, String queueId)
private ReplicationSourceInterface	ReplicationSourceManager.createCatalogReplicationSource(RegionInfo regionInfo)	Create, initialize, and start the Catalog ReplicationSource.
private ReplicationSourceInterface	ReplicationSourceManager.createSource(String queueId, ReplicationPeer replicationPeer)
ReplicationSourceInterface	ReplicationSourceManager.getSource(String peerId)	Get the normal source for a given peer
ReplicationSourceInterface	ReplicationSource.startup()
ReplicationSourceInterface	ReplicationSourceInterface.startup()	Start the replication

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

Modifier and Type	Method	Description
List<ReplicationSourceInterface>	ReplicationSourceManager.getOldSources()	Get a list of all the recovered sources of this rs
List<ReplicationSourceInterface>	ReplicationSourceManager.getSources()	Get a list of all the normal sources of this rs

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

Modifier and Type	Method	Description
void	ReplicationSourceManager.logPositionAndCleanOldLogs(ReplicationSourceInterface source, WALEntryBatch entryBatch)	This method will log the current position to storage.
(package private) void	ReplicationSourceManager.removeRecoveredSource(ReplicationSourceInterface src)	Clear the metrics and related replication queue of the specified old source
(package private) void	ReplicationSourceManager.removeSource(ReplicationSourceInterface src)	Clear the metrics and related replication queue of the specified old source

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

Modifier and Type	Method	Description
void	ReplicationLoad.buildReplicationLoad(List<ReplicationSourceInterface> sources, MetricsSink skMetrics)	buildReplicationLoad