Package com.continuent.tungsten.replicator.pipeline

Interface Summary

Schedule	Denotes a schedule, which monitors and directs task execution.
StageTask	Denotes a Runnable task that implements stage processing.
TaskScheduler	Denotes a class that provides scheduling information for stage tasks.

Class Summary

Pipeline	Stores the information related to a replication pipeline, which is a set of independent processing stages.
ShardProgress	Tracks statistics for an individual shard, which is identified by a shard ID.
SimpleSchedule	Defines a basic schedule implementation that tracks watches on events and task termination logic.
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.

Enum Summary

TaskState

Defines the processing states of a task.