com.continuent.tungsten.replicator.filter
Interface Filter

All Superinterfaces:

ReplicatorPlugin

All Known Subinterfaces:

FilterManualProperties

All Known Implementing Classes:

BidiRemoteSlaveFilter, BuildAuditTable, BuildIndexTable, CaseMappingFilter, CDCMetadataFilter, ColumnNameFilter, ConsistencyCheckFilter, DatabaseTransformFilter, DummyFilter, EnumToStringFilter, EventMetadataFilter, HeartbeatFilter, JavaScriptFilter, LoggingFilter, MySQLSessionSupportFilter, OptimizeUpdatesFilter, PrimaryKeyFilter, PrintEventFilter, RenameFilter, ReplicateColumnsFilter, ReplicateFilter, SetToStringFilter, ShardFilter, ShardFilter, TimeDelayFilter, TungstenTableCDCTransformFilter

public interface Filter
extends ReplicatorPlugin

This class defines a Filter

Version:

1.0

Author:

Teemu Ollakka

Method Summary

ReplDBMSEvent

filter(ReplDBMSEvent event) Filter the event.

Methods inherited from interface com.continuent.tungsten.replicator.plugin.ReplicatorPlugin

configure, prepare, release

Method Detail

filter

ReplDBMSEvent filter(ReplDBMSEvent event)
                     throws ReplicatorException,
                            java.lang.InterruptedException

Filter the event. Filters may transform the event or return null if the event should be discarded. Filters must be prepared to be interrupted, which mechanism is used to cancel processing.

Parameters:

event - An event to be filtered

Returns:

Filtered ReplDBMSEvent or null

Throws:

ReplicatorException - Thrown if there is a processing error

java.lang.InterruptedException - Must be thrown if the filter is interrupted or the replicator may hang