Maintains a collection of peers to replicate to, and randomly selects a
single peer to replicate to per set of data to replicate. Also handles
keeping track of peer availability.
Default maximum number of times a replication sink can be reported as bad before
it will no longer be provided as a sink for replication without the pool of
replication sinks being refreshed.
Default ratio of the total number of peer cluster region servers to consider
private final float ratio;
Instantiate for a single replication peer cluster.
conn connection to the peer cluster
peerClusterId identifier of the peer cluster
endpoint replication endpoint for inter cluster replication
conf HBase configuration, used for determining replication source ratio and bad peer
Get a randomly-chosen replication sink to replicate to.
- a replication sink to replicate to
LOG.info("Current list of sinks is out of date, updating");
throw new IOException("No replication sinks are available");
as being bad (i.e. an attempt to replicate to it
failed). If a single SinkPeer is reported as bad more than
replication.bad.sink.threshold times, it will be removed
from the pool of potential replication targets.
The SinkPeer that had a failed replication attempt on it
Wraps a replication region server sink to provide the ability to identify