org.apache.hadoop.hbase.replication.regionserver

Class HBaseInterClusterReplicationEndpoint

java.lang.Object

AbstractService

org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint

org.apache.hadoop.hbase.replication.regionserver.HBaseInterClusterReplicationEndpoint

All Implemented Interfaces:

ReplicationEndpoint

public class HBaseInterClusterReplicationEndpoint
extends HBaseReplicationEndpoint

A 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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	HBaseInterClusterReplicationEndpoint.Replicator

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint

HBaseReplicationEndpoint.PeerRegionServerListener

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

ReplicationEndpoint.Context, ReplicationEndpoint.ReplicateContext

Field Summary

Fields inherited from class org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

ctx, REPLICATION_WALENTRYFILTER_CONFIG_KEY

Constructor Summary

Constructors

Constructor and Description
HBaseInterClusterReplicationEndpoint()

Method Summary

Modifier and Type	Method and Description
protected HBaseInterClusterReplicationEndpoint.Replicator	createReplicator(java.util.List<Entry> entries, int ordinal)
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

Methods inherited from class org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint

abort, disconnect, doStart, fetchSlavesAddresses, getLastRegionServerUpdate, getPeerUUID, getRegionServers, getZkw, isAborted, reconnect, setRegionServers, start, stop

Methods inherited from class org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

canReplicateToSameCluster, getNamespaceTableCfWALEntryFilter, getScopeWALEntryFilter, getWALEntryfilter, isStarting, peerConfigUpdated

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning

Constructor Detail

HBaseInterClusterReplicationEndpoint

public HBaseInterClusterReplicationEndpoint()

Method Detail

init

public void init(ReplicationEndpoint.Context context)
          throws java.io.IOException

Description copied from interface: ReplicationEndpoint

Initialize the replication endpoint with the given context.

Specified by:

init in interface ReplicationEndpoint

Overrides:

init in class BaseReplicationEndpoint

Parameters:

context - replication context

Throws:

java.io.IOException

sleepForRetries

protected boolean sleepForRetries(java.lang.String msg,
                                  int sleepMultiplier)

Do the sleeping logic

Parameters:

msg - Why we sleep

sleepMultiplier - by how many times the default sleeping time is augmented

Returns:

True if sleepMultiplier is < maxRetriesMultiplier

replicate

public boolean replicate(ReplicationEndpoint.ReplicateContext replicateContext)

Do the shipping logic

Parameters:

replicateContext - a context where WAL entries and other parameters can be obtained.

isPeerEnabled

protected boolean isPeerEnabled()

doStop

protected void doStop()

Overrides:

doStop in class HBaseReplicationEndpoint

createReplicator

protected HBaseInterClusterReplicationEndpoint.Replicator createReplicator(java.util.List<Entry> entries,
                                                                           int ordinal)