Class ReplicationSource

java.lang.Object
org.apache.hadoop.hbase.replication.regionserver.ReplicationSource
All Implemented Interfaces:
ReplicationSourceInterface
Direct Known Subclasses:
CatalogReplicationSource, RecoveredReplicationSource

@Private public class ReplicationSource extends Object implements ReplicationSourceInterface
Class that handles the source of a replication stream. Currently does not handle more than 1 slave cluster. For each slave cluster it selects a random number of peers using a replication ratio. For example, if replication ration = 0.1 and slave cluster has 100 region servers, 10 will be selected.

A stream is considered down when we cannot contact a region server on the peer cluster for more than 55 seconds by default.