| 2074 | } |
| 2075 | |
| 2076 | void ClientRequestState::ClearResultCache() { |
| 2077 | if (result_cache_ == nullptr) return; |
| 2078 | // Update result set cache metrics and mem limit accounting. |
| 2079 | ImpaladMetrics::RESULTSET_CACHE_TOTAL_NUM_ROWS->Increment(-result_cache_->size()); |
| 2080 | int64_t total_bytes = result_cache_->ByteSize(); |
| 2081 | ImpaladMetrics::RESULTSET_CACHE_TOTAL_BYTES->Increment(-total_bytes); |
| 2082 | Coordinator* coordinator = GetCoordinator(); |
| 2083 | if (coordinator != nullptr) { |
| 2084 | DCHECK(coordinator->query_mem_tracker() != nullptr); |
| 2085 | coordinator->query_mem_tracker()->Release(total_bytes); |
| 2086 | } |
| 2087 | result_cache_.reset(); |
| 2088 | } |
| 2089 | |
| 2090 | void ClientRequestState::UpdateExecState(ExecState exec_state) { |
| 2091 | { |