Method CatalogHandler

be/src/service/impala-http-handler.cc:1043–1107

}

void ImpalaHttpHandler::CatalogHandler(const Webserver::WebRequest& req,
    Document* document) {
  TGetDbsResult get_dbs_result;
  Status status = server_->exec_env_->frontend()->GetDbs(NULL, NULL, &get_dbs_result);
  if (!status.ok()) {
    Value error(status.GetDetail(), document->GetAllocator());
    document->AddMember("error", error, document->GetAllocator());
    return;
  }

  TGetCatalogInfoResult catalog_info;
  status = server_->exec_env_->frontend()->GetCatalogInfo(&catalog_info);

  if (!status.ok()) {
    Value error(status.GetDetail().c_str(), document->GetAllocator());
    document->AddMember("error", error, document->GetAllocator());
    return;
  }

  Value info(kArrayType);
  for (const string& str: catalog_info.info) {
    Value str_val(str.c_str(), document->GetAllocator());
    Value value(kObjectType);
    value.AddMember("value", str_val, document->GetAllocator());
    info.PushBack(value, document->GetAllocator());
  }
  document->AddMember("info", info, document->GetAllocator());

  Value databases(kArrayType);
  for (const TDatabase& db: get_dbs_result.dbs) {
    Value database(kObjectType);
    Value str(db.db_name, document->GetAllocator());
    database.AddMember("name", str, document->GetAllocator());

    TGetTablesResult get_table_results;
    status = server_->exec_env_->frontend()->GetTableNames(
        db.db_name, nullptr, nullptr, &get_table_results);
    if (!status.ok()) {
      Value error(status.GetDetail(), document->GetAllocator());
      database.AddMember("error", error, document->GetAllocator());
      continue;
    }

    Value table_array(kArrayType);
    for (const string& table: get_table_results.tables) {
      Value table_obj(kObjectType);
      if(!FLAGS_use_local_catalog){
        // Creates hyperlinks for /catalog_object. This is disabled in local catalog mode
        Value fq_name(Substitute("$0.$1", db.db_name, table),
            document->GetAllocator());
        table_obj.AddMember("fqtn", fq_name, document->GetAllocator());
      }
      Value table_name(table, document->GetAllocator());
      table_obj.AddMember("name", table_name, document->GetAllocator());
      table_array.PushBack(table_obj, document->GetAllocator());
    }
    database.AddMember("num_tables", table_array.Size(), document->GetAllocator());
    database.AddMember("tables", table_array, document->GetAllocator());