Skip to main content

execute_pipeline_streaming

osp_cli::dsl::eval::engine

Function execute_pipeline_streaming 

Source 
pub fn execute_pipeline_streaming<I>(
    rows: I,
    stages: &[String],
) -> Result<OutputResult>
where
    I: IntoIterator<Item = Row>,
    I::IntoIter: 'static,
Expand description

Execute a pipeline from any row iterator.

This keeps flat row stages on an iterator-backed path until a stage requires full materialization (for example sort/group/aggregate/jq).