| 155 | } // ImpalaServer::ExecuteAndFetchAllHS2 |
| 156 | |
| 157 | Status ImpalaServer::SubmitAndWait(const string& user_name, const string& sql, |
| 158 | TUniqueId& new_session_id, TUniqueId& new_query_id, const QueryOptionMap& query_opts, |
| 159 | const bool persist_in_db) { |
| 160 | |
| 161 | RETURN_IF_ERROR(OpenSession(user_name, new_session_id, query_opts)); |
| 162 | RETURN_IF_ERROR(SubmitQuery(sql, new_session_id, new_query_id, persist_in_db)); |
| 163 | |
| 164 | if (const auto& debug_action = query_opts.find(TImpalaQueryOptions::DEBUG_ACTION); |
| 165 | debug_action != query_opts.end()) { |
| 166 | RETURN_IF_ERROR(DebugAction(debug_action->second, "INTERNAL_SERVER_AFTER_SUBMIT")); |
| 167 | } |
| 168 | |
| 169 | return WaitForResults(new_query_id); |
| 170 | } // ImpalaServer::SubmitAndWait |
| 171 | |
| 172 | Status ImpalaServer::WaitForResults(TUniqueId& query_id) { |
| 173 | QueryHandle query_handle; |
nothing calls this directly
no test coverage detected