Skip to main content
Source

pub async fn create_catalog( &self, name: String, table_format: String, location: String, type: String, credential: String, datasource: String, ) -> Result<CreateCatalogResponse, KineticaError>

Create a catalog

Creates a catalog, which contains the location and connection information for a deltalake catalog that is external to the database.

  • name - Name of the catalog to be created.
  • table_format - Table format (iceberg, hudi, deltalake).
  • location - Location of the catalog in ‘http[s]://[server[:port]]]’ format.
  • r#type - Type of the catalog (REST (unity, polaris, tabular), nessie, hive, glue).
  • credential - Name of the credential object to be used in catalog.
  • datasource - Password for the remote system user; may be an empty string.
Source

pub async fn create_catalog_with_opts( &self, name: String, table_format: String, location: String, type: String, credential: String, datasource: String, options: CreateCatalogRequestOptions, ) -> Result<CreateCatalogResponse, KineticaError>

Create a catalog

Creates a catalog, which contains the location and connection information for a deltalake catalog that is external to the database.

  • name - Name of the catalog to be created.
  • table_format - Table format (iceberg, hudi, deltalake).
  • location - Location of the catalog in ‘http[s]://[server[:port]]]’ format.
  • r#type - Type of the catalog (REST (unity, polaris, tabular), nessie, hive, glue).
  • credential - Name of the credential object to be used in catalog.
  • datasource - Password for the remote system user; may be an empty string.
  • options - The optional parameters; any left unset take the server’s defaults.

Sends a pre-built CreateCatalogRequest to the /create/catalog endpoint.

Sends a pre-built CreateCatalogRequest to a specific worker URL, bypassing HA head-node selection. Used for multi-head access.