Reference

Classes

Core classes

Pipeline

An ordered chain of processing stages.

Stage

A single processing step in a pipeline.

Source

A data source feeding a pipeline.

Sink

A data destination for pipeline output.

Functions

Public functions

run_pipeline()

One-shot helper: source -> stages -> sink.

validate_schema()

Validate data against a schema version.