Method CatalogObjectsUrlCallback

be/src/catalog/catalog-server.cc:1422–1467

}

void CatalogServer::CatalogObjectsUrlCallback(const Webserver::WebRequest& req,
    Document* document) {
  const auto& args = req.parsed_args;
  Webserver::ArgumentMap::const_iterator object_type_arg = args.find("object_type");
  Webserver::ArgumentMap::const_iterator object_name_arg = args.find("object_name");
  Webserver::ArgumentMap::const_iterator json_arg = args.find("json");
  if (object_type_arg != args.end() && object_name_arg != args.end()) {
    TCatalogObjectType::type object_type =
        TCatalogObjectTypeFromName(object_type_arg->second);

    // Get the object type and name from the topic entry key
    TCatalogObject request;
    Status status =
        TCatalogObjectFromObjectName(object_type, object_name_arg->second, &request);

    if (json_arg != args.end()) {
      // Get the JSON string from FE since Thrift doesn't have a cpp implementation for
      // SimpleJsonProtocol (THRIFT-2476), so we use it's java implementation.
      // TODO: switch to use cpp implementation of SimpleJsonProtocol after THRIFT-2476
      //  is resolved.
      string json_str;
      if (status.ok()) status = catalog_->GetJsonCatalogObject(request, &json_str);
      if (status.ok()) {
        Value debug_string(json_str, document->GetAllocator());
        document->AddMember("json_string", debug_string, document->GetAllocator());
      }
    } else {
      // Get the object and dump its contents.
      TCatalogObject result;
      if (status.ok()) status = catalog_->GetCatalogObject(request, &result);
      if(status.ok()) {
        Value debug_string(
            ThriftDebugStringNoThrow(result), document->GetAllocator());
        document->AddMember("thrift_string", debug_string, document->GetAllocator());
      }
    }
    if (!status.ok()) {
      Value error(status.GetDetail(), document->GetAllocator());
      document->AddMember("error", error, document->GetAllocator());
    }
  } else {
    Value error("Please specify values for the object_type and object_name parameters.",
        document->GetAllocator());
    document->AddMember("error", error, document->GetAllocator());
  }
}

void CatalogServer::OperationUsageUrlCallback(
    const Webserver::WebRequest& req, Document* document) {