| 72 | int NumBatches() override { return num_batches_; } |
| 73 | |
| 74 | Future<std::shared_ptr<RecordBatch>> ScanBatch(int index) override { |
| 75 | DCHECK_EQ(num_scanned_++, index); |
| 76 | return reader_->ReadNextAsync(); |
| 77 | } |
| 78 | |
| 79 | int64_t EstimatedDataBytes(int) override { return block_size_; } |
| 80 |
nothing calls this directly
no test coverage detected