@InterfaceAudience.Private public class HBaseInterClusterReplicationEndpoint extends HBaseReplicationEndpoint
ReplicationEndpoint
implementation for replicating to another HBase cluster.
For the 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.HBaseReplicationEndpoint.PeerRegionServerListener
ReplicationEndpoint.Context, ReplicationEndpoint.ReplicateContext
ctx
Constructor and Description |
---|
HBaseInterClusterReplicationEndpoint() |
Modifier and Type | Method and Description |
---|---|
protected void |
doStop() |
void |
init(ReplicationEndpoint.Context context)
Initialize the replication endpoint with the given context.
|
protected boolean |
isPeerEnabled() |
boolean |
replicate(ReplicationEndpoint.ReplicateContext replicateContext)
Do the shipping logic
|
protected boolean |
sleepForRetries(java.lang.String msg,
int sleepMultiplier)
Do the sleeping logic
|
abort, disconnect, doStart, fetchSlavesAddresses, getLastRegionServerUpdate, getPeerUUID, getRegionServers, getZkw, isAborted, reconnect, setRegionServers
canReplicateToSameCluster, getScopeWALEntryFilter, getTableCfWALEntryFilter, getWALEntryfilter
public HBaseInterClusterReplicationEndpoint()
public void init(ReplicationEndpoint.Context context) throws java.io.IOException
ReplicationEndpoint
init
in interface ReplicationEndpoint
init
in class BaseReplicationEndpoint
context
- replication contextjava.io.IOException
protected boolean sleepForRetries(java.lang.String msg, int sleepMultiplier)
msg
- Why we sleepsleepMultiplier
- by how many times the default sleeping time is augmentedsleepMultiplier
is < maxRetriesMultiplier
public boolean replicate(ReplicationEndpoint.ReplicateContext replicateContext)
replicateContext
- a context where WAL entries and other
parameters can be obtained.protected boolean isPeerEnabled()
protected void doStop()
doStop
in class HBaseReplicationEndpoint