@InterfaceAudience.LimitedPrivate(value="Replication") @InterfaceStability.Evolving public class ClusterMarkingEntryFilter extends Object implements WALEntryFilter
Constructor and Description |
---|
ClusterMarkingEntryFilter(UUID clusterId,
UUID peerClusterId,
ReplicationEndpoint replicationEndpoint) |
public ClusterMarkingEntryFilter(UUID clusterId, UUID peerClusterId, ReplicationEndpoint replicationEndpoint)
clusterId
- id of this clusterpeerClusterId
- of the other clusterreplicationEndpoint
- ReplicationEndpoint which will handle the actual replicationpublic WAL.Entry filter(WAL.Entry entry)
WALEntryFilter
filter
in interface WALEntryFilter
entry
- Entry to filterCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.