Skip to main content

execute_pipeline

Function execute_pipeline 

Source
pub fn execute_pipeline(
    rows: Vec<Row>,
    stages: &[String],
) -> Result<OutputResult>
Expand description

Execute a pipeline starting from plain rows.

This is the lower-level row entrypoint used by tests and internal helpers. Like apply_pipeline, it starts with wants_copy = false.