Struct deltalake::data_catalog::UnityCatalog

pub struct UnityCatalog { /* private fields */ }

Databricks Unity Catalog

Implementations

impl UnityCatalog

pub async fn list_catalogs( &self ) -> Result<ListCatalogsResponse, DataCatalogError>

Gets an array of catalogs in the metastore. If the caller is the metastore admin, all catalogs will be retrieved. Otherwise, only catalogs owned by the caller (or for which the caller has the USE_CATALOG privilege) will be retrieved. There is no guarantee of a specific ordering of the elements in the array.

pub async fn list_schemas( &self, catalog_name: impl AsRef<str> ) -> Result<ListSchemasResponse, DataCatalogError>

List all schemas for a catalog in the metastore.

If the caller is the metastore admin or the owner of the parent catalog, all schemas for the catalog will be retrieved. Otherwise, only schemas owned by the caller (or for which the caller has the USE_SCHEMA privilege) will be retrieved. There is no guarantee of a specific ordering of the elements in the array.

Parameters

• catalog_name: Parent catalog for schemas of interest.

pub async fn get_schema( &self, catalog_name: impl AsRef<str>, schema_name: impl AsRef<str> ) -> Result<GetSchemaResponse, DataCatalogError>

Gets the specified schema within the metastore.#

The caller must be a metastore admin, the owner of the schema, or a user that has the USE_SCHEMA privilege on the schema.

pub async fn list_table_summaries( &self, catalog_name: impl AsRef<str>, schema_name_pattern: impl AsRef<str> ) -> Result<ListTableSummariesResponse, DataCatalogError>

Gets an array of summaries for tables for a schema and catalog within the metastore.

The table summaries returned are either:

• summaries for all tables (within the current metastore and parent catalog and schema), when the user is a metastore admin, or:
• summaries for all tables and schemas (within the current metastore and parent catalog) for which the user has ownership or the SELECT privilege on the table and ownership or USE_SCHEMA privilege on the schema, provided that the user also has ownership or the USE_CATALOG privilege on the parent catalog.

There is no guarantee of a specific ordering of the elements in the array.

pub async fn get_table( &self, catalog_id: impl AsRef<str>, database_name: impl AsRef<str>, table_name: impl AsRef<str> ) -> Result<GetTableResponse, DataCatalogError>

Gets a table from the metastore for a specific catalog and schema.

The caller must be a metastore admin, be the owner of the table and have the USE_CATALOG privilege on the parent catalog and the USE_SCHEMA privilege on the parent schema, or be the owner of the table and have the SELECT privilege on it as well.

Parameters

Trait Implementations

impl DataCatalog for UnityCatalog

fn get_table_storage_location<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, catalog_id: Option<String>, database_name: &'life1 str, table_name: &'life2 str ) -> Pin<Box<dyn Future<Output = Result<String, DataCatalogError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, UnityCatalog: 'async_trait,

Get the table storage location from the UnityCatalog

impl Debug for UnityCatalog

fn fmt(&self, fmt: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.