org.apache.hadoop.hbase.replication

Class ClusterMarkingEntryFilter

java.lang.Object

org.apache.hadoop.hbase.replication.ClusterMarkingEntryFilter

All Implemented Interfaces:

WALEntryFilter

@InterfaceAudience.LimitedPrivate(value="Replication")
 @InterfaceStability.Evolving
public class ClusterMarkingEntryFilter
extends Object
implements WALEntryFilter

Filters out entries with our peerClusterId (i.e. already replicated) and marks all other entries with our clusterID

Field Summary

Fields

Modifier and Type	Field and Description
private UUID	clusterId
private UUID	peerClusterId
private ReplicationEndpoint	replicationEndpoint

Constructor Summary

Constructors

Constructor and Description
ClusterMarkingEntryFilter(UUID clusterId, UUID peerClusterId, ReplicationEndpoint replicationEndpoint)

Method Summary

Modifier and Type	Method and Description
WAL.Entry	filter(WAL.Entry entry) Applies the filter, possibly returning a different Entry instance.

Methods inherited from class java.lang.Object

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

Field Detail

clusterId

private UUID clusterId

peerClusterId

private UUID peerClusterId

replicationEndpoint

private ReplicationEndpoint replicationEndpoint

Constructor Detail

ClusterMarkingEntryFilter

public ClusterMarkingEntryFilter(UUID clusterId,
                                 UUID peerClusterId,
                                 ReplicationEndpoint replicationEndpoint)

Parameters:

clusterId - id of this cluster

peerClusterId - of the other cluster

replicationEndpoint - ReplicationEndpoint which will handle the actual replication

Method Detail

filter

public WAL.Entry filter(WAL.Entry entry)

Description copied from interface: WALEntryFilter

Applies the filter, possibly returning a different Entry instance. If null is returned, the entry will be skipped.

Specified by:

filter in interface WALEntryFilter

Parameters:

entry - Entry to filter

Returns:

a (possibly modified) Entry to use. Returning null or an entry with no cells will cause the entry to be skipped for replication.