com.continuent.tungsten.replicator.filter
Class ReplicateColumnsFilter

java.lang.Object
  com.continuent.tungsten.replicator.filter.ReplicateColumnsFilter

All Implemented Interfaces:

Filter, ReplicatorPlugin

public class ReplicateColumnsFilter
extends java.lang.Object
implements Filter

Filter to remove columns frow RowChangeData

Version:

1.0

Author:

Jeff Mace

See Also:

Pattern, Matcher

Constructor Summary

ReplicateColumnsFilter()

Method Summary

void	configure(PluginContext context) Complete plug-in configuration.
ReplDBMSEvent	filter(ReplDBMSEvent event) Filter the event.
java.lang.String	fullyQualifiedName(java.lang.String schema, java.lang.String table, java.lang.String column)
void	prepare(PluginContext context) Prepare plug-in for use.
void	release(PluginContext context) Release all resources used by plug-in.
void	setDo(java.lang.String doFilter)
void	setDoFilter(java.lang.String doFilter) Define a comma-separated list of tables with optional column names (e.g., table1,table2.column,etc.) to replicate.
void	setIgnore(java.lang.String ignore)
void	setIgnoreFilter(java.lang.String ignoreFilter) Define a comma-separated list of tables with optional column names (e.g., table1,table2.column,etc.) to ignore.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicateColumnsFilter

public ReplicateColumnsFilter()

Method Detail

setDoFilter

public void setDoFilter(java.lang.String doFilter)

Define a comma-separated list of tables with optional column names (e.g., table1,table2.column,etc.) to replicate. If set, only operations that match the list will be forwarded.

setDo

public void setDo(java.lang.String doFilter)

setIgnoreFilter

public void setIgnoreFilter(java.lang.String ignoreFilter)

Define a comma-separated list of tables with optional column names (e.g., table1,table2.column,etc.) to ignore. If set, all operations that match the list will be ignored.

Parameters:

ignoreFilter -

setIgnore

public void setIgnore(java.lang.String ignore)

filter

public ReplDBMSEvent filter(ReplDBMSEvent event)
                     throws ReplicatorException

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.

Specified by:

filter in interface Filter

Parameters:

event - An event to be filtered

Returns:

Filtered ReplDBMSEvent or null

Throws:

ReplicatorException - Thrown if there is a processing error

See Also:

Filter.filter(com.continuent.tungsten.replicator.event.ReplDBMSEvent)

fullyQualifiedName

public java.lang.String fullyQualifiedName(java.lang.String schema,
                                           java.lang.String table,
                                           java.lang.String column)

configure

public void configure(PluginContext context)
               throws ReplicatorException

Complete plug-in configuration. This is called after setters are invoked at the time that the replicator goes through configuration.

Specified by:

configure in interface ReplicatorPlugin

Throws:

ReplicatorException - Thrown if configuration is incomplete or fails

See Also:

ReplicatorPlugin.configure(com.continuent.tungsten.replicator.plugin.PluginContext)

prepare

public void prepare(PluginContext context)
             throws ReplicatorException

Prepare plug-in for use. This method is assumed to allocate all required resources. It is called before the plug-in performs any operations.

Specified by:

prepare in interface ReplicatorPlugin

Throws:

ReplicatorException - Thrown if resource allocation fails

See Also:

ReplicatorPlugin.prepare(com.continuent.tungsten.replicator.plugin.PluginContext)

release

public void release(PluginContext context)
             throws ReplicatorException

Release all resources used by plug-in. This is called before the plug-in is deallocated.

Specified by:

release in interface ReplicatorPlugin

Throws:

ReplicatorException - Thrown if resource deallocation fails

See Also:

ReplicatorPlugin.release(com.continuent.tungsten.replicator.plugin.PluginContext)