| 203 | } |
| 204 | |
| 205 | Status HdfsScanNode::AddDiskIoRanges(const vector<ScanRange*>& ranges, |
| 206 | EnqueueLocation enqueue_location) { |
| 207 | DCHECK_GT(shared_state_->RemainingScanRangeSubmissions(), 0); |
| 208 | RETURN_IF_ERROR(reader_context_->AddScanRanges(ranges, enqueue_location)); |
| 209 | if (!ranges.empty()) ThreadTokenAvailableCb(runtime_state_->resource_pool()); |
| 210 | return Status::OK(); |
| 211 | } |
| 212 | |
| 213 | int64_t HdfsScanNode::EstimateScannerThreadMemConsumption(RuntimeState* state) const { |
| 214 | // Start with the minimum I/O buffer requirement. |
no test coverage detected