Method QueryStateToJson

be/src/service/impala-http-handler.cc:586–716

}

void ImpalaHttpHandler::QueryStateToJson(const QueryStateRecord& record,
    Value* value, Document* document, bool inflight) {
  Value user(record.effective_user, document->GetAllocator());
  value->AddMember("effective_user", user, document->GetAllocator());

  Value default_db(record.default_db, document->GetAllocator());
  value->AddMember("default_db", default_db, document->GetAllocator());

  // Redact the query string
  std::string tmp_stmt = RedactCopy(record.stmt);
  if(FLAGS_query_stmt_size && tmp_stmt.length() > FLAGS_query_stmt_size) {
    tmp_stmt = tmp_stmt.substr(0, FLAGS_query_stmt_size).append("...");
  }
  Value stmt(tmp_stmt, document->GetAllocator());
  value->AddMember("stmt", stmt, document->GetAllocator());

  Value stmt_type(_TStmtType_VALUES_TO_NAMES.find(record.stmt_type)->second,
      document->GetAllocator());
  value->AddMember("stmt_type", stmt_type, document->GetAllocator());

  Value start_time(ToStringFromUnixMicros(record.start_time_us,
      TimePrecision::Millisecond), document->GetAllocator());
  value->AddMember("start_time", start_time, document->GetAllocator());

  Value end_time(ToStringFromUnixMicros(record.end_time_us,
      TimePrecision::Millisecond), document->GetAllocator());
  value->AddMember("end_time", end_time, document->GetAllocator());

  vector<string>::const_iterator it = std::find(record.event_sequence.labels.begin(),
      record.event_sequence.labels.end(),
      Coordinator::PROFILE_EVENT_LABEL_FIRST_ROW_FETCHED);
  int64_t first_fetch_ns = 0;
  if (it != record.event_sequence.labels.end()) {
    first_fetch_ns = record.event_sequence.timestamps[it
        - record.event_sequence.labels.begin()];
  }
  const string& printed_first_fetch = PrettyPrinter::Print(first_fetch_ns,
      TUnit::TIME_NS);
  Value val_first_fetch(printed_first_fetch, document->GetAllocator());
  value->AddMember("first_fetch", val_first_fetch, document->GetAllocator());

  const string& printed_client_fetch_duration = PrettyPrinter::Print(
      record.client_fetch_wait_time_ns, TUnit::TIME_NS);
  Value val_client_fetch_duration(printed_client_fetch_duration,
      document->GetAllocator());
  value->AddMember("client_fetch_duration", val_client_fetch_duration,
      document->GetAllocator());

  // record.end_time_us might still be zero if the query is not yet done
  // Use the current Unix time in that case. Note that the duration can be
  // negative if a system clock reset happened after the query was initiated.
  int64_t end_time_us = record.end_time_us > 0LL ? record.end_time_us : UnixMicros();
  int64_t duration_us = end_time_us - record.start_time_us;
  const string& printed_duration = PrettyPrinter::Print(duration_us * NANOS_PER_MICRO,
      TUnit::TIME_NS);
  Value val_duration(printed_duration, document->GetAllocator());
  value->AddMember("duration", val_duration, document->GetAllocator());