@InterfaceAudience.Private public abstract class BaseReplicationEndpoint extends org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService implements ReplicationEndpoint
ReplicationEndpoint
s. For internal use. Uses our internal
Guava.ReplicationEndpoint.Context, ReplicationEndpoint.ReplicateContext
Modifier and Type | Field and Description |
---|---|
protected ReplicationEndpoint.Context |
ctx |
private static org.slf4j.Logger |
LOG |
static String |
REPLICATION_WALENTRYFILTER_CONFIG_KEY |
Constructor and Description |
---|
BaseReplicationEndpoint() |
Modifier and Type | Method and 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
|
addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, doCancelStart, doStart, doStop, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, getPeerUUID, isRunning, replicate, start, stop
private static final org.slf4j.Logger LOG
public static final String REPLICATION_WALENTRYFILTER_CONFIG_KEY
protected ReplicationEndpoint.Context ctx
public BaseReplicationEndpoint()
public void init(ReplicationEndpoint.Context context) throws IOException
ReplicationEndpoint
init
in interface ReplicationEndpoint
context
- replication contextIOException
- error occur when initialize the endpoint.public void peerConfigUpdated(ReplicationPeerConfig rpc)
ReplicationPeerConfigListener
peerConfigUpdated
in interface ReplicationPeerConfigListener
rpc
- The updated ReplicationPeerConfigpublic WALEntryFilter getWALEntryfilter()
getWALEntryfilter
in interface ReplicationEndpoint
WALEntryFilter
or null.protected WALEntryFilter getScopeWALEntryFilter()
protected WALEntryFilter getNamespaceTableCfWALEntryFilter()
public boolean canReplicateToSameCluster()
ReplicationEndpoint
canReplicateToSameCluster
in interface ReplicationEndpoint
public boolean isStarting()
ReplicationEndpoint
true
is this service is STARTING (but not yet RUNNING).isStarting
in interface ReplicationEndpoint
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.