Uses of Package
com.continuent.tungsten.replicator.pipeline

Packages that use com.continuent.tungsten.replicator.pipeline

com.continuent.tungsten.replicator.conf
com.continuent.tungsten.replicator.pipeline
com.continuent.tungsten.replicator.plugin

Classes in com.continuent.tungsten.replicator.pipeline used by com.continuent.tungsten.replicator.conf

Pipeline
Stores the information related to a replication pipeline, which is a set of independent processing stages.

Stage
Stores the implementation of a single replicator processing stage, which consists of extract, filtering, and apply operations.

Classes in com.continuent.tungsten.replicator.pipeline used by com.continuent.tungsten.replicator.pipeline

Pipeline
Stores the information related to a replication pipeline, which is a set of independent processing stages.

Schedule
Denotes a schedule, which monitors and directs task execution.

ShardProgress
Tracks statistics for an individual shard, which is identified by a shard ID.

SingleThreadStageTask
Implements thread logic for single-threaded stage execution.

Stage
Stores the implementation of a single replicator processing stage, which consists of extract, filtering, and apply operations.

StageProgressTracker
Tracks the current status of replication and implements event watches.

StageTaskGroup
This class encapsulates a group of tasks that run together in a single stage.

TaskProgress
Tracks statistics for an individual task, which is identified by a task ID.

TaskState
Defines the processing states of a task.

Classes in com.continuent.tungsten.replicator.pipeline used by com.continuent.tungsten.replicator.plugin

Stage
Stores the implementation of a single replicator processing stage, which consists of extract, filtering, and apply operations.