Struct Pipeline 

pub struct Pipeline { /* private fields */ }

Fluent builder for data pipelines.

Implementations

impl Pipeline

pub fn scan(df: DataFrame) -> Self

Start a pipeline by scanning a source DataFrame.

pub fn filter(self, predicate: DExpr) -> Self

Add a filter step to the pipeline.

pub fn group_by(self, keys: Vec<String>) -> Self

Add a group-by step to the pipeline.

pub fn summarize(self, keys: Vec<String>, aggs: Vec<(String, DExpr)>) -> Self

Add a summarize (aggregate) step to the pipeline.

pub fn select(self, columns: Vec<String>) -> Self

Add a column projection step to the pipeline.

pub fn inner_join(self, right: DataFrame, left_on: &str, right_on: &str) -> Self

Add an inner join step to the pipeline.

pub fn left_join(self, right: DataFrame, left_on: &str, right_on: &str) -> Self

Add a left join step to the pipeline.

pub fn cross_join(self, right: DataFrame) -> Self

Add a cross (cartesian) join step to the pipeline.

pub fn collect(self) -> Result<DataFrame, DataError>

Optimize and execute the pipeline.

pub fn plan(&self) -> &LogicalPlan

Get the logical plan (for inspection/testing).