[[acero::export]]
| 193 | |
| 194 | // [[acero::export]] |
| 195 | cpp11::list ExecPlanReader__batches( |
| 196 | const std::shared_ptr<arrow::RecordBatchReader>& reader) { |
| 197 | auto result = RunWithCapturedRIfPossible<arrow::RecordBatchVector>( |
| 198 | [&]() { return reader->ToRecordBatches(); }); |
| 199 | return arrow::r::to_r_list(ValueOrStop(result)); |
| 200 | } |
| 201 | |
| 202 | // [[acero::export]] |
| 203 | std::shared_ptr<arrow::Table> Table__from_ExecPlanReader( |
no test coverage detected