| 194 | return scan_tasks_[batch_number].batch_future; |
| 195 | } |
| 196 | int64_t EstimatedDataBytes(int batch_number) override { |
| 197 | return util::TotalBufferSize(*scan_tasks_[batch_number].batch); |
| 198 | } |
| 199 | int NumBatches() override { return static_cast<int>(scan_tasks_.size()); } |
| 200 | |
| 201 | // ### Unit Test API ### |
nothing calls this directly
no test coverage detected