| 1150 | } |
| 1151 | |
| 1152 | Result<std::function<Future<std::optional<ExecBatch>>()>> MakeReaderGenerator( |
| 1153 | std::shared_ptr<RecordBatchReader> reader, ::arrow::internal::Executor* io_executor, |
| 1154 | int max_q, int q_restart) { |
| 1155 | auto batch_it = MakeMapIterator( |
| 1156 | [](std::shared_ptr<RecordBatch> batch) { |
| 1157 | return std::make_optional(ExecBatch(*batch)); |
| 1158 | }, |
| 1159 | MakeIteratorFromReader(reader)); |
| 1160 | |
| 1161 | return MakeBackgroundGenerator(std::move(batch_it), io_executor, max_q, q_restart); |
| 1162 | } |
| 1163 | |
| 1164 | } // namespace acero |
| 1165 | } // namespace arrow |
nothing calls this directly
no test coverage detected