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.
Source
pub async fn create_catalog_raw( &self, request: &CreateCatalogRequest, ) -> Result<CreateCatalogResponse, KineticaError>
Sends a pre-built CreateCatalogRequest to the /create/catalog endpoint.
Source
pub async fn create_catalog_from_url( &self, url: &str, request: &CreateCatalogRequest, ) -> Result<CreateCatalogResponse, KineticaError>
Sends a pre-built CreateCatalogRequest to a specific worker URL, bypassing HA head-node selection. Used for multi-head access.