| 176 | } |
| 177 | |
| 178 | void HdfsScanner::CloseInternal() { |
| 179 | DCHECK(!is_closed_); |
| 180 | if (decompressor_.get() != nullptr) { |
| 181 | decompressor_->Close(); |
| 182 | decompressor_.reset(); |
| 183 | } |
| 184 | for (auto& entry : conjunct_evals_map_) { |
| 185 | ScalarExprEvaluator::Close(entry.second, state_); |
| 186 | } |
| 187 | expr_perm_pool_->FreeAll(); |
| 188 | context_->expr_results_pool()->FreeAll(); |
| 189 | obj_pool_.Clear(); |
| 190 | stream_ = nullptr; |
| 191 | context_->ClearStreams(); |
| 192 | is_closed_ = true; |
| 193 | } |
| 194 | |
| 195 | Status HdfsScanner::InitializeWriteTuplesFn(HdfsPartitionDescriptor* partition, |
| 196 | THdfsFileFormat::type type, const string& scanner_name) { |
nothing calls this directly
no test coverage detected