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