| 1959 | } |
| 1960 | |
| 1961 | Status ImpalaServer::GetActiveQueryHandle( |
| 1962 | const TUniqueId& query_id, QueryHandle* query_handle, bool skip_rpcs) { |
| 1963 | DCHECK(query_handle != nullptr); |
| 1964 | shared_ptr<QueryDriver> query_driver = GetQueryDriver(query_id); |
| 1965 | if (UNLIKELY(query_driver == nullptr)) { |
| 1966 | Status err = GetInterruptedStatus(query_id); |
| 1967 | VLOG(1) << err.GetDetail(); |
| 1968 | return err; |
| 1969 | } |
| 1970 | query_handle->SetHandle(query_driver, query_driver->GetActiveClientRequestState()); |
| 1971 | if (!skip_rpcs) { |
| 1972 | // Update RPC Stats before every call. This is done here to minimize the |
| 1973 | // pending set size and keep the profile updated while the query is executing. |
| 1974 | (*query_handle)->UnRegisterCompletedRPCs(); |
| 1975 | (*query_handle)->RegisterRPC(); |
| 1976 | } |
| 1977 | return Status::OK(); |
| 1978 | } |
| 1979 | |
| 1980 | Status ImpalaServer::GetQueryHandle( |
| 1981 | const TUniqueId& query_id, QueryHandle* query_handle, bool return_unregistered) { |
nothing calls this directly
no test coverage detected