Package org.apache.hadoop.hbase.replication

Class BaseReplicationEndpoint

java.lang.Object

org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

All Implemented Interfaces:

ReplicationEndpoint, ReplicationPeerConfigListener, org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service

Direct Known Subclasses:

HBaseReplicationEndpoint, VerifyWALEntriesReplicationEndpoint

@Private
public abstract class BaseReplicationEndpoint
extends org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService
implements ReplicationEndpoint

A Base implementation for ReplicationEndpoints. For internal use. Uses our internal Guava.

Nested Class Summary

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

ReplicationEndpoint.Context, ReplicationEndpoint.ReplicateContext

Nested classes/interfaces inherited from interface org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service

org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service.Listener, org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service.State

Field Summary

Fields

Modifier and Type	Field	Description
protected ReplicationEndpoint.Context	ctx
private static final org.slf4j.Logger	LOG
static final String	REPLICATION_WALENTRYFILTER_CONFIG_KEY

Constructor Summary

Constructors

Constructor	Description
BaseReplicationEndpoint()

Method Summary

Modifier and Type	Method	Description
boolean	canReplicateToSameCluster()	Whether or not, the replication endpoint can replicate to it's source cluster with the same UUID
protected WALEntryFilter	getNamespaceTableCfWALEntryFilter()	Returns a WALEntryFilter for checking replication per table and CF.
protected WALEntryFilter	getScopeWALEntryFilter()	Returns a WALEntryFilter for checking the scope.
WALEntryFilter	getWALEntryfilter()	Returns a default set of filters
void	init(ReplicationEndpoint.Context context)	Initialize the replication endpoint with the given context.
boolean	isStarting()	Returns Return true is this service is STARTING (but not yet RUNNING).
void	peerConfigUpdated(ReplicationPeerConfig rpc)	Callback method for when users update the ReplicationPeerConfig for this peer

Methods inherited from class org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, doCancelStart, doStart, doStop, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

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

awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, getPeerUUID, isRunning, replicate, start, stop

Field Details

LOG

private static final org.slf4j.Logger LOG

REPLICATION_WALENTRYFILTER_CONFIG_KEY

public static final String REPLICATION_WALENTRYFILTER_CONFIG_KEY

See Also:

• Constant Field Values

ctx

protected ReplicationEndpoint.Context ctx

Constructor Details

BaseReplicationEndpoint

public BaseReplicationEndpoint()

Method Details

init

public void init(ReplicationEndpoint.Context context)
          throws IOException

Description copied from interface: ReplicationEndpoint

Initialize the replication endpoint with the given context.

Specified by:

init in interface ReplicationEndpoint

Parameters:

context - replication context

Throws:

IOException - error occur when initialize the endpoint.

peerConfigUpdated

public void peerConfigUpdated(ReplicationPeerConfig rpc)

Description copied from interface: ReplicationPeerConfigListener

Callback method for when users update the ReplicationPeerConfig for this peer

Specified by:

peerConfigUpdated in interface ReplicationPeerConfigListener

Parameters:

rpc - The updated ReplicationPeerConfig

getWALEntryfilter

public WALEntryFilter getWALEntryfilter()

Returns a default set of filters

Specified by:

getWALEntryfilter in interface ReplicationEndpoint

Returns:

a WALEntryFilter or null.

getScopeWALEntryFilter

protected WALEntryFilter getScopeWALEntryFilter()

Returns a WALEntryFilter for checking the scope. Subclasses can return null if they don't want this filter

getNamespaceTableCfWALEntryFilter

protected WALEntryFilter getNamespaceTableCfWALEntryFilter()

Returns a WALEntryFilter for checking replication per table and CF. Subclasses can return null if they don't want this filter

canReplicateToSameCluster

public boolean canReplicateToSameCluster()

Description copied from interface: ReplicationEndpoint

Whether or not, the replication endpoint can replicate to it's source cluster with the same UUID

Specified by:

canReplicateToSameCluster in interface ReplicationEndpoint

isStarting

public boolean isStarting()

Description copied from interface: ReplicationEndpoint

Returns Return true is this service is STARTING (but not yet RUNNING).

Specified by:

isStarting in interface ReplicationEndpoint