| 246 | task_group_(std::move(task_group)) {} |
| 247 | |
| 248 | Status Init(std::shared_ptr<io::InputStream> input) { |
| 249 | ARROW_ASSIGN_OR_RAISE(auto it, |
| 250 | io::MakeInputStreamIterator(input, read_options_.block_size)); |
| 251 | return MakeReadaheadIterator(std::move(it), task_group_->parallelism()) |
| 252 | .Value(&buffer_iterator_); |
| 253 | } |
| 254 | |
| 255 | Result<std::shared_ptr<Table>> Read() override { |
| 256 | auto block_it = MakeChunkingIterator(std::move(buffer_iterator_), |
no test coverage detected