Module pipeline 

Re-exports

pub use crate::config::ConcurrencyConfig;

Modules

concurrent

sequential

Structs

CommitterConfig

IngestionConfig

Per-pipeline ingestion settings.

Traits

Processor

Implementors of this trait are responsible for transforming checkpoint into rows for their table.