pub fn build_stream<T: Transaction>(
    plan: LogicalPlan,
    transaction: &RefCell<T>
) -> BoxedExecutor