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 and 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 and Description
(package private) AtomicReference<ReplicationSourceInterface>	ReplicationSourceManager.catalogReplicationSource A special ReplicationSource for hbase:meta Region Read Replicas.
private List<ReplicationSourceInterface>	ReplicationSourceManager.oldsources
private ConcurrentMap<String,ReplicationSourceInterface>	ReplicationSourceManager.sources

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

Modifier and Type	Method and 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	ReplicationSourceInterface.startup() Start the replication
ReplicationSourceInterface	ReplicationSource.startup()

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

Modifier and Type	Method and 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 and 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 and Description
void	ReplicationLoad.buildReplicationLoad(List<ReplicationSourceInterface> sources, MetricsSink skMetrics) buildReplicationLoad