[[acero::export]]
| 225 | |
| 226 | // [[acero::export]] |
| 227 | std::shared_ptr<ExecPlanReader> ExecPlan_run( |
| 228 | const std::shared_ptr<acero::ExecPlan>& plan, |
| 229 | const std::shared_ptr<acero::ExecNode>& final_node, cpp11::strings metadata) { |
| 230 | // For now, don't require R to construct SinkNodes. |
| 231 | // Instead, just pass the node we should collect as an argument. |
| 232 | arrow::AsyncGenerator<std::optional<compute::ExecBatch>> sink_gen; |
| 233 | |
| 234 | MakeExecNodeOrStop("sink", plan.get(), {final_node.get()}, |
| 235 | acero::SinkNodeOptions{&sink_gen}); |
| 236 | |
| 237 | StopIfNotOk(plan->Validate()); |
| 238 | |
| 239 | // Attach metadata to the schema |
| 240 | auto out_schema = final_node->output_schema(); |
| 241 | if (metadata.size() > 0) { |
| 242 | auto kv = strings_to_kvm(metadata); |
| 243 | out_schema = out_schema->WithMetadata(kv); |
| 244 | } |
| 245 | |
| 246 | return std::make_shared<ExecPlanReader>(plan, out_schema, sink_gen); |
| 247 | } |
| 248 | |
| 249 | // [[acero::export]] |
| 250 | std::string ExecPlan_ToString(const std::shared_ptr<acero::ExecPlan>& plan) { |
no test coverage detected