@InterfaceAudience.LimitedPrivate(value="Replication") @InterfaceStability.Evolving public class ClusterMarkingEntryFilter extends Object implements WALEntryFilter
Modifier and Type | Field and Description |
---|---|
private UUID |
clusterId |
private UUID |
peerClusterId |
private ReplicationEndpoint |
replicationEndpoint |
Constructor and Description |
---|
ClusterMarkingEntryFilter(UUID clusterId,
UUID peerClusterId,
ReplicationEndpoint replicationEndpoint) |
Modifier and Type | Method and Description |
---|---|
WAL.Entry |
filter(WAL.Entry entry)
Applies the filter, possibly returning a different Entry instance.
|
private UUID peerClusterId
private 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.