Method QueryProfileHelper

be/src/service/impala-http-handler.cc:355–393

}

void ImpalaHttpHandler::QueryProfileHelper(const Webserver::WebRequest& req,
    Document* document, TRuntimeProfileFormat::type format, bool internal_profile) {
  TUniqueId unique_id;
  stringstream ss;
  Status status = ParseIdFromRequest(req, &unique_id, "query_id");
  if (!status.ok()) {
    ss << status.GetDetail();
  } else {
    ImpalaServer::RuntimeProfileOutput runtime_profile;
    if (internal_profile) {
      Value query_id_val(PrintId(unique_id), document->GetAllocator());
      document->AddMember("query_id", query_id_val, document->GetAllocator());
      document->AddMember("internal_profile", true, document->GetAllocator());
    }
    if (format != TRuntimeProfileFormat::JSON) {
      runtime_profile.string_output = &ss;
    }
    runtime_profile.json_output = document;
    status = server_->GetRuntimeProfileOutput(unique_id, "", format, &runtime_profile);
    if (!status.ok()) {
      ss.str(Substitute("Could not obtain runtime profile: $0", status.GetDetail()));
    }
  }
  // JSON format contents already been added inside document in GetRuntimeProfileOutput()
  if (format != TRuntimeProfileFormat::JSON){
    Value profile(ss.str(), document->GetAllocator());
    document->AddMember("contents", profile, document->GetAllocator());
  } else if (internal_profile) {
    if (!status.ok()) {
      Value error(ss.str(), document->GetAllocator());
      document->AddMember("error", error, document->GetAllocator());
      return;
    }
    // Add OK Status like other handlers have. These status lines could be
    // eliminated if error was handled uniformly in all handlers.
    Value json_status("OK");
    document->AddMember("status", json_status, document->GetAllocator());
  }
}

void ImpalaHttpHandler::QueryProfileEncodedHandler(const Webserver::WebRequest& req,
    Document* document) {