public class ReplicationSinkManager extends Object
|Modifier and Type||Class and Description|
Wraps a replication region server sink to provide the ability to identify it.
|Constructor and Description|
Instantiate for a single replication peer cluster.
|Modifier and Type||Method and Description|
Get a randomly-chosen replication sink to replicate to.
public ReplicationSinkManager(HConnection conn, String peerClusterId, HBaseReplicationEndpoint endpoint, org.apache.hadoop.conf.Configuration conf)
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 threshold
public ReplicationSinkManager.SinkPeer getReplicationSink() throws IOException
public void reportBadSink(ReplicationSinkManager.SinkPeer sinkPeer)
SinkPeeras 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.
sinkPeer- The SinkPeer that had a failed replication attempt on it
Copyright © 2015 The Apache Software Foundation. All Rights Reserved.