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
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
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
(package private) static ReplicationSourceInterface	ReplicationSourceFactory.create(org.apache.hadoop.conf.Configuration conf, ReplicationQueueId queueId)
private ReplicationSourceInterface	ReplicationSourceManager.createRefreshedSource(ReplicationQueueId queueId, ReplicationPeer peer)
private ReplicationSourceInterface	ReplicationSourceManager.createSource(ReplicationQueueData queueData, 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
private void	ReplicationSourceManager.addRecoveredSource(ReplicationSourceInterface src, ReplicationPeerImpl oldPeer, ReplicationQueueId claimedQueueId, PriorityQueue<org.apache.hadoop.fs.Path> walFiles)
(package private) void	ReplicationSourceManager.cleanOldLogs(String log, boolean inclusive, ReplicationSourceInterface source)	Cleans a log file and all older logs from replication queue.
private void	ReplicationSourceManager.cleanOldLogs(NavigableSet<String> wals, ReplicationSourceInterface source)
(package private) void	ReplicationSourceManager.finishRecoveredSource(ReplicationSourceInterface src)
void	ReplicationSourceManager.logPositionAndCleanOldLogs(ReplicationSourceInterface source, WALEntryBatch entryBatch)	This method will log the current position to storage.
private boolean	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 sinkMetrics)	buildReplicationLoad