@InterfaceAudience.Private public class RegionReplicaReplicationEndpoint extends HBaseReplicationEndpoint
ReplicationEndpoint endpoint which receives the WAL edits from the
WAL, and sends the edits to replicas of regions.HBaseReplicationEndpoint.PeerRegionServerListenerReplicationEndpoint.Context, ReplicationEndpoint.ReplicateContextctx| Constructor and Description |
|---|
RegionReplicaReplicationEndpoint() |
| 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 void |
doStart() |
protected void |
doStop() |
protected WALEntryFilter |
getScopeWALEntryFilter()
Returns a WALEntryFilter for checking the scope.
|
protected WALEntryFilter |
getSkipReplayedEditsFilter() |
WALEntryFilter |
getWALEntryfilter()
Returns a default set of filters
|
void |
init(ReplicationEndpoint.Context context)
Initialize the replication endpoint with the given context.
|
boolean |
replicate(ReplicationEndpoint.ReplicateContext replicateContext)
Replicate the given set of entries (in the context) to the other cluster.
|
abort, disconnect, fetchSlavesAddresses, getLastRegionServerUpdate, getPeerUUID, getRegionServers, getZkw, isAborted, reconnect, setRegionServersclose, getTableCfWALEntryFilter, peerConfigUpdatedisRunning, notifyFailed, notifyStarted, notifyStopped, start, startAndWait, state, stop, stopAndWait, toStringpublic WALEntryFilter getWALEntryfilter()
BaseReplicationEndpointgetWALEntryfilter in interface ReplicationEndpointgetWALEntryfilter in class BaseReplicationEndpointWALEntryFilter or null.protected WALEntryFilter getSkipReplayedEditsFilter()
public void init(ReplicationEndpoint.Context context) throws IOException
ReplicationEndpointinit in interface ReplicationEndpointinit in class BaseReplicationEndpointcontext - replication contextIOExceptionprotected void doStart()
doStart in class HBaseReplicationEndpointprotected void doStop()
doStop in class HBaseReplicationEndpointpublic boolean replicate(ReplicationEndpoint.ReplicateContext replicateContext)
ReplicationEndpointreplicateContext - a context where WAL entries and other
parameters can be obtained.public boolean canReplicateToSameCluster()
ReplicationEndpointcanReplicateToSameCluster in interface ReplicationEndpointcanReplicateToSameCluster in class BaseReplicationEndpointprotected WALEntryFilter getScopeWALEntryFilter()
BaseReplicationEndpointgetScopeWALEntryFilter in class BaseReplicationEndpointCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.