Function create_pipeline

pub fn create_pipeline<F>(
    sources: &[Node],
    operators: Vec<Box<dyn Operator>>,
    sink_nodes: Vec<(usize, Node, Rc<RefCell<u32>>)>,
    lp_arena: &Arena<IR>,
    expr_arena: &mut Arena<AExpr>,
    to_physical: F,
    verbose: bool,
    sink_cache: &mut PlHashMap<usize, Box<dyn SinkTrait>>,
    callbacks: &mut CallBacks,
) -> PolarsResult<PipeLine>
where
    F: Fn(&ExprIR, &Arena<AExpr>, &SchemaRef) -> PolarsResult<Arc<dyn PhysicalPipedExpr>>,