| 418 | } |
| 419 | |
| 420 | Future<> WhenBuffered(const std::vector<int>& row_groups, |
| 421 | const std::vector<int>& column_indices) const { |
| 422 | if (!cached_source_) { |
| 423 | return Status::Invalid("Must call PreBuffer before WhenBuffered"); |
| 424 | } |
| 425 | std::vector<::arrow::io::ReadRange> ranges; |
| 426 | for (int row : row_groups) { |
| 427 | for (int col : column_indices) { |
| 428 | ranges.push_back( |
| 429 | ComputeColumnChunkRange(file_metadata_.get(), source_size_, row, col)); |
| 430 | } |
| 431 | } |
| 432 | return cached_source_->WaitFor(ranges); |
| 433 | } |
| 434 | |
| 435 | // Metadata/footer parsing. Divided up to separate sync/async paths, and to use |
| 436 | // exceptions for error handling (with the async path converting to Future/Status). |
nothing calls this directly
no test coverage detected