[[acero::export]]
| 474 | |
| 475 | // [[acero::export]] |
| 476 | std::shared_ptr<acero::ExecNode> ExecNode_SourceNode( |
| 477 | const std::shared_ptr<acero::ExecPlan>& plan, |
| 478 | const std::shared_ptr<arrow::RecordBatchReader>& reader) { |
| 479 | arrow::acero::RecordBatchReaderSourceNodeOptions options{reader}; |
| 480 | return MakeExecNodeOrStop("record_batch_reader_source", plan.get(), {}, options); |
| 481 | } |
| 482 | |
| 483 | // [[acero::export]] |
| 484 | std::shared_ptr<acero::ExecNode> ExecNode_TableSourceNode( |
no test coverage detected