| 400 | } |
| 401 | |
| 402 | void AddBatch(std::shared_ptr<RecordBatch> batch) { |
| 403 | active_fragment->scan_tasks_.emplace_back(std::move(batch)); |
| 404 | active_fragment->has_started_.push_back(false); |
| 405 | } |
| 406 | |
| 407 | std::unique_ptr<MockDataset> Finish() { |
| 408 | return std::make_unique<MockDataset>(std::move(dataset_schema), std::move(fragments)); |
no test coverage detected