| 140 | } |
| 141 | |
| 142 | void HdfsScanNodeMt::Close(RuntimeState* state) { |
| 143 | if (is_closed()) return; |
| 144 | if (scanner_.get() != nullptr) scanner_->Close(nullptr); |
| 145 | scanner_.reset(); |
| 146 | scanner_ctx_.reset(); |
| 147 | HdfsScanNodeBase::Close(state); |
| 148 | } |
| 149 | |
| 150 | Status HdfsScanNodeMt::AddDiskIoRanges( |
| 151 | const vector<ScanRange*>& ranges, EnqueueLocation enqueue_location) { |
no test coverage detected