Uses of Interface
com.continuent.tungsten.replicator.plugin.ReplicatorPlugin

Packages that use ReplicatorPlugin

com.continuent.tungsten.replicator.applier
com.continuent.tungsten.replicator.applier.batch
com.continuent.tungsten.replicator.channel
com.continuent.tungsten.replicator.conf
com.continuent.tungsten.replicator.consistency
com.continuent.tungsten.replicator.event
com.continuent.tungsten.replicator.extractor
com.continuent.tungsten.replicator.extractor.mysql
com.continuent.tungsten.replicator.extractor.oracle
com.continuent.tungsten.replicator.extractor.postgresql
com.continuent.tungsten.replicator.filter
com.continuent.tungsten.replicator.heartbeat
com.continuent.tungsten.replicator.loader
com.continuent.tungsten.replicator.pipeline
com.continuent.tungsten.replicator.plugin
com.continuent.tungsten.replicator.prefetch
com.continuent.tungsten.replicator.service
com.continuent.tungsten.replicator.storage
com.continuent.tungsten.replicator.storage.parallel
com.continuent.tungsten.replicator.thl

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.applier

Subinterfaces of ReplicatorPlugin in com.continuent.tungsten.replicator.applier

interface	Applier Denotes an applier that can process events with full metadata.
interface	ParallelApplier Denotes an applier that extends normal Applier capabilities to allow parallel operation.
interface	RawApplier Denotes an applier, which is responsible for applying raw DBMS events to a database or other replication target.

Classes in com.continuent.tungsten.replicator.applier that implement ReplicatorPlugin

class	ApplierWrapper This class wraps a basic Applier so that it handles ReplDBMSEvent values with assigned sequence numbers.
class	DrizzleApplier Stub applier class that automatically constructs url from Drizzle-specific properties like host, port, and service.
class	DummyApplier
class	JdbcApplier Implements a DBMS implementation-independent applier.
class	JdbcPrefetcher Implements a JDBC prefetcher.
class	MongoApplier Implements an applier for MongoDB.
class	MySQLApplier Stub applier class that automatically constructs url from Oracle-specific properties like host, port, and service.
class	MySQLDrizzleApplier
class	OracleApplier
class	PostgreSQLApplier

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.applier.batch

Subinterfaces of ReplicatorPlugin in com.continuent.tungsten.replicator.applier.batch

interface

ScriptExecutor Denotes a class capable of executing a batch load script.

Classes in com.continuent.tungsten.replicator.applier.batch that implement ReplicatorPlugin

class	InfiniDBBatchApplier
class	JavascriptExecutor Represents a class to execute a Javascript batch load script.
class	NativeScriptExecutor Represents a class to execute a native batch script.
class	SimpleBatchApplier Implements an applier that bulk loads data into a SQL database via CSV files.
class	VerticaStreamBatchApplier Implements an applier that bulk loads data into a Vertica database via stream interface.

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.channel

Classes in com.continuent.tungsten.replicator.channel that implement ReplicatorPlugin

class

ChannelAssignmentService Provides a service interface to the shard-to-channel assignment table.

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.conf

Methods in com.continuent.tungsten.replicator.conf that return ReplicatorPlugin

ReplicatorPlugin	ReplicatorRuntime.getExtension(java.lang.String name) Returns the named extension or null if the extension does not exist.
protected ReplicatorPlugin	ReplicatorRuntime.loadAndConfigurePlugin(java.lang.String prefix, java.lang.String name) Generic code to load and configure a plugin.

Methods in com.continuent.tungsten.replicator.conf with parameters of type ReplicatorPlugin

static void	ReplicatorRuntime.configurePlugin(ReplicatorPlugin plugin, PluginContext context) Call configure method on a plugin class.
static void	ReplicatorRuntime.preparePlugin(ReplicatorPlugin plugin, PluginContext context) Call prepare method on a plugin class.
static void	ReplicatorRuntime.releasePlugin(ReplicatorPlugin plugin, PluginContext context) Call release method on a plugin class, warning on errors.

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.consistency

Classes in com.continuent.tungsten.replicator.consistency that implement ReplicatorPlugin

class

ConsistencyCheckFilter This class implements a filter to find consistency checks.

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.event

Classes in com.continuent.tungsten.replicator.event that implement ReplicatorPlugin

class

EventMetadataFilter This filter events newly extracted from the database log to answer the following key questions.

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.extractor

Subinterfaces of ReplicatorPlugin in com.continuent.tungsten.replicator.extractor

interface	Extractor Denotes an extractor that extracts DBMSReplEvents with full metadata.
interface	ParallelExtractor Denotes an extractor that extends normal Extractor capabilities to allow parallel operation.
interface	RawExtractor Denotes an extractor that is responsible for extracting raw events from a database or other replication source.

Classes in com.continuent.tungsten.replicator.extractor that implement ReplicatorPlugin

class	DummyExtractor This class defines a DummyExtractor
class	ExtractorWrapper This class wraps a basic Extractor so that it returns ReplDBMSEvent values with assigned sequence numbers.

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.extractor.mysql

Classes in com.continuent.tungsten.replicator.extractor.mysql that implement ReplicatorPlugin

class

MySQLExtractor This class defines a MySQLExtractor

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.extractor.oracle

Classes in com.continuent.tungsten.replicator.extractor.oracle that implement ReplicatorPlugin

class	OracleCDCExtractor
class	OracleCDCReaderExtractor
class	OracleExtractor Defines a replication event extractor, which reads events from Oracle via a scoket connection to the actual C based Oracle extractor.

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.extractor.postgresql

Classes in com.continuent.tungsten.replicator.extractor.postgresql that implement ReplicatorPlugin

class

PostgreSQLSlonyExtractor Class extracting events from Slony's log tables, generated by triggers.

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.filter

Subinterfaces of ReplicatorPlugin in com.continuent.tungsten.replicator.filter

interface	Filter This class defines a Filter
interface	FilterManualProperties This class defines a more raw Filter by the fact that its properties are not automatically set by using setter methods.

Classes in com.continuent.tungsten.replicator.filter that implement ReplicatorPlugin

class	BidiRemoteSlaveFilter Implements a filter to suppress events that originate on the local service for remote slaves.
class	BuildAuditTable Filter to transform ROW INSERT/UPDATE changes into an audit table for a specified list of schema.table pairs.
class	BuildIndexTable Filter to transform a specific database name to a new value using Java regular expression rules.
class	CaseMappingFilter Transforms database, table and column names into upper or lower case.
class	CDCMetadataFilter Filter which for each row change transaction adds a change data capture row to a corresponding change table. Change table structure: original columns ..., CDC_OP_TYPE, CDC_TIMESTAMP, CDC_SEQUENCE_NUMBER Filter automatically generates a CDC_SEQUENCE_NUMBER primary key value for the change table.
class	ColumnNameFilter This class defines a ColumnNameFilter.
class	DatabaseTransformFilter Filter to transform a specific database name to a new value using Java regular expression rules.
class	DummyFilter Placeholder class that can be used to check that filters load correctly.
class	EnumToStringFilter EnumToStringFilter transforms enum data type values to corresponding string representation as follows: 1.
class	JavaScriptFilter This filter allows to develop JavaScript filters without coding any Java at all. User's script will be precompiled once and then called on every filtered event. Script must define the following function: function filter(event) - called on every filtered ReplDBMSEvent. filter(event) function's return value is handled as follows: a.
class	LoggingFilter Logs the filtered event at the log4j 'info' level.
class	MySQLSessionSupportFilter Filter to support session specific temp tables and variables
class	OptimizeUpdatesFilter Removes "SET key1=value1" parts of an UPDATE if the values updated are the same as current values in the key part.
class	PrimaryKeyFilter This class defines a PrimaryKeyFilter
class	PrintEventFilter Filter to transform a specific database name to a new value using Java regular expression rules.
class	RenameFilter Filter which renames schemas, tables and columns based on a file provided.
class	ReplicateColumnsFilter Filter to remove columns frow RowChangeData
class	ReplicateFilter Implements a filter to either apply or ignore operations on particular schemas and/or tables.
class	SetToStringFilter SetToStringFilter transforms MySQL SET data type values to corresponding string representation as follows: 1.
class	ShardFilter Ignores or replicates a database using rules similar to MySQL ignore-db and
class	TimeDelayFilter Filter to delay a transaction until a particular point in time has passed.
class	TungstenTableCDCTransformFilter Filter to transform a specific database name and table into a new value.

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.heartbeat

Classes in com.continuent.tungsten.replicator.heartbeat that implement ReplicatorPlugin

class

HeartbeatFilter Implements a filter to detect heartbeat table updates and add appropriate metadata to the event.

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.loader

Classes in com.continuent.tungsten.replicator.loader that implement ReplicatorPlugin

class	CSVLoader Load THL events from a series of CSV files
class	JdbcLoader
class	Loader This class defines the base class for all THL Loader extractor classes.
class	MySQLLoader

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.pipeline

Classes in com.continuent.tungsten.replicator.pipeline that implement ReplicatorPlugin

class	Pipeline Stores the information related to a replication pipeline, which is a set of independent processing stages.
class	Stage Stores the implementation of a single replicator processing stage, which consists of extract, filtering, and apply operations.
class	StageTaskGroup This class encapsulates a group of tasks that run together in a single stage.

Methods in com.continuent.tungsten.replicator.pipeline with parameters of type ReplicatorPlugin

protected void	Stage.configurePlugin(ReplicatorPlugin plugin, PluginContext context) Call configure method on a plugin class.
protected void	Stage.preparePlugin(ReplicatorPlugin plugin, PluginContext context) Call prepare method on a plugin class.
protected void	Stage.releasePlugin(ReplicatorPlugin plugin, PluginContext context) Call release method on a plugin class, warning on errors.

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.plugin

Methods in com.continuent.tungsten.replicator.plugin that return ReplicatorPlugin

ReplicatorPlugin	PluginContext.getExtension(java.lang.String name) Returns the named extension or null if the extension does not exist.
ReplicatorPlugin	PluginSpecification.instantiate(int id) Instantiate the plugin and assign properties.
static ReplicatorPlugin	PluginLoader.load(java.lang.String name) Load plugin implementation.

Methods in com.continuent.tungsten.replicator.plugin with parameters of type ReplicatorPlugin

static java.lang.Object	PluginConfigurator.getParameter(ReplicatorPlugin plugin, java.lang.String name) Call getter method for given replicator plugin.
static void	PluginConfigurator.setParameter(ReplicatorPlugin plugin, java.lang.String name, java.lang.Object value) Call setter method for given ReplicatorPlugin.

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.prefetch

Classes in com.continuent.tungsten.replicator.prefetch that implement ReplicatorPlugin

class	PrefetchApplier Implements a JDBC prefetcher.
class	PrefetchStore Implements a specialized store for handling slave prefetch from another replicator.

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.service

Subinterfaces of ReplicatorPlugin in com.continuent.tungsten.replicator.service

interface

PipelineService Denotes a plugin that is a free-standing service for replicator pipelines accessible from all stages.

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.storage

Subinterfaces of ReplicatorPlugin in com.continuent.tungsten.replicator.storage

interface	ParallelStore Denotes a storage component that partitions transactions into disjoint sets.
interface	Store Denotes a storage component that holds replication events.

Classes in com.continuent.tungsten.replicator.storage that implement ReplicatorPlugin

class	InMemoryMultiQueue Implements an in-memory queue store with multiple queues.
class	InMemoryMultiQueueApplier Implements Extractor and Applier interfaces for an in-memory queue.
class	InMemoryQueueAdapter Implements Extractor and Applier interfaces for an in-memory queue.
class	InMemoryQueueStore Implements an in-memory event store.
class	InMemoryTransactionalQueue Implements an in-memory queue store that applies events from multiple task threads (i.e., channels) into a single centralized queue.
class	InMemoryTransactionalQueueApplier Implements Applier interface for an in-memory transactional queue.

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.storage.parallel

Classes in com.continuent.tungsten.replicator.storage.parallel that implement ReplicatorPlugin

class	ParallelQueueApplier Implements Applier interface for a parallel queue.
class	ParallelQueueExtractor Implements ParallelExtractor interface for a parallel queue.
class	ParallelQueueStore Implements an parallel event store.

Uses of ReplicatorPlugin in com.continuent.tungsten.replicator.thl

Classes in com.continuent.tungsten.replicator.thl that implement ReplicatorPlugin

class	Connector This class defines a Connector
class	ConnectorHandler This class defines a ConnectorHandler
class	RemoteTHLExtractor Implements an extractor to pull events from a remote THL.
class	THL Implements a standard Store interface on the THL (transaction history log).
class	THLParallelQueue Implements a parallel event store based on on-disk queues.
class	THLParallelQueueApplier Implements Applier interface for a THL parallel queue.
class	THLParallelQueueExtractor Implements ParallelExtractor interface for a parallel queue.
class	THLStoreApplier Implements Extractor and Applier interface for a transaction history log (THL).
class	THLStoreExtractor Implements Extractor interface for a transaction history log (THL).