pub fn build_streaming_query_executor( node: Node, ir_arena: &mut Arena<IR>, expr_arena: &mut Arena<AExpr>, ) -> Result<Box<dyn Executor>, PolarsError>