polars_pipe::pipeline

Function execute_pipeline

Source 
pub fn execute_pipeline(
    state: ExecutionState,
    pipelines: Vec<PipeLine>,
) -> PolarsResult<DataFrame>
Expand description

Executes all branches and replaces operators and sinks during execution to ensure we materialize.