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