| 167 | } |
| 168 | |
| 169 | Status HdfsScanNodeMt::GetNextScanRangeToRead( |
| 170 | io::ScanRange** scan_range, bool* needs_buffers) { |
| 171 | // With deterministic scan ranges, use the same code as non-mt-dop |
| 172 | if (deterministic_scanrange_assignment_) { |
| 173 | return reader_context_->GetNextUnstartedRange(scan_range, needs_buffers); |
| 174 | } |
| 175 | RETURN_IF_ERROR(shared_state_->GetNextScanRange(runtime_state_, scan_range)); |
| 176 | if (*scan_range != nullptr) { |
| 177 | RETURN_IF_ERROR(reader_context_->StartScanRange(*scan_range, needs_buffers)); |
| 178 | } |
| 179 | return Status::OK(); |
| 180 | } |
| 181 | } |
nothing calls this directly
no test coverage detected