Struct SqlCatalog 

pub struct SqlCatalog { /* private fields */ }

Implementations

impl SqlCatalog

pub async fn new( url: &str, name: &str, object_store: ObjectStoreBuilder, ) -> Result<Self, Error>

pub fn catalog_list(&self) -> Arc<SqlCatalogList>

impl SqlCatalog

pub fn duplicate(&self, name: &str) -> Self

Trait Implementations

impl Catalog for SqlCatalog

fn name(&self) -> &str

Catalog name

fn create_namespace<'life0, 'life1, 'async_trait>( &'life0 self, namespace: &'life1 Namespace, properties: Option<HashMap<String, String>>, ) -> Pin<Box<dyn Future<Output = Result<HashMap<String, String>, IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Create a namespace in the catalog

fn drop_namespace<'life0, 'life1, 'async_trait>( &'life0 self, _namespace: &'life1 Namespace, ) -> Pin<Box<dyn Future<Output = Result<(), IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Drop a namespace in the catalog

fn load_namespace<'life0, 'life1, 'async_trait>( &'life0 self, _namespace: &'life1 Namespace, ) -> Pin<Box<dyn Future<Output = Result<HashMap<String, String>, IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Load the namespace properties from the catalog

fn update_namespace<'life0, 'life1, 'async_trait>( &'life0 self, _namespace: &'life1 Namespace, _updates: Option<HashMap<String, String>>, _removals: Option<Vec<String>>, ) -> Pin<Box<dyn Future<Output = Result<(), IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update the namespace properties in the catalog

fn namespace_exists<'life0, 'life1, 'async_trait>( &'life0 self, _namespace: &'life1 Namespace, ) -> Pin<Box<dyn Future<Output = Result<bool, IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Check if a namespace exists

fn list_tabulars<'life0, 'life1, 'async_trait>( &'life0 self, namespace: &'life1 Namespace, ) -> Pin<Box<dyn Future<Output = Result<Vec<Identifier>, IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Lists all tables, views, and materialized views in the given namespace.

fn list_namespaces<'life0, 'life1, 'async_trait>( &'life0 self, _parent: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Namespace>, IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Lists all namespaces under an optional parent namespace.

fn tabular_exists<'life0, 'life1, 'async_trait>( &'life0 self, identifier: &'life1 Identifier, ) -> Pin<Box<dyn Future<Output = Result<bool, IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Checks if a table, view, or materialized view exists in the catalog.

fn drop_table<'life0, 'life1, 'async_trait>( &'life0 self, identifier: &'life1 Identifier, ) -> Pin<Box<dyn Future<Output = Result<(), IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Drops a table from the catalog and deletes all associated data and metadata files.

fn drop_view<'life0, 'life1, 'async_trait>( &'life0 self, identifier: &'life1 Identifier, ) -> Pin<Box<dyn Future<Output = Result<(), IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Drops a view from the catalog and deletes its metadata.

fn drop_materialized_view<'life0, 'life1, 'async_trait>( &'life0 self, identifier: &'life1 Identifier, ) -> Pin<Box<dyn Future<Output = Result<(), IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Drops a materialized view from the catalog and deletes its metadata and data files.

fn load_tabular<'life0, 'async_trait>( self: Arc<Self>, identifier: &'life0 Identifier, ) -> Pin<Box<dyn Future<Output = Result<Tabular, IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Loads a table, view, or materialized view from the catalog.

fn create_table<'async_trait>( self: Arc<Self>, identifier: Identifier, create_table: CreateTable, ) -> Pin<Box<dyn Future<Output = Result<Table, IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait,

Creates a new table in the catalog with the specified configuration.

fn create_view<'async_trait>( self: Arc<Self>, identifier: Identifier, create_view: CreateView<Option<()>>, ) -> Pin<Box<dyn Future<Output = Result<View, IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait,

Creates a new view in the catalog with the specified configuration.

fn create_materialized_view<'async_trait>( self: Arc<Self>, identifier: Identifier, create_view: CreateMaterializedView, ) -> Pin<Box<dyn Future<Output = Result<MaterializedView, IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait,

Creates a new materialized view in the catalog with the specified configuration.

fn update_table<'async_trait>( self: Arc<Self>, commit: CommitTable, ) -> Pin<Box<dyn Future<Output = Result<Table, IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait,

Updates a table’s metadata by applying the specified commit operation.

fn update_view<'async_trait>( self: Arc<Self>, commit: CommitView<Option<()>>, ) -> Pin<Box<dyn Future<Output = Result<View, IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait,

Updates a view’s metadata by applying the specified commit operation.

fn update_materialized_view<'async_trait>( self: Arc<Self>, commit: CommitView<FullIdentifier>, ) -> Pin<Box<dyn Future<Output = Result<MaterializedView, IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait,

Updates a materialized view’s metadata by applying the specified commit operation.

fn register_table<'life0, 'async_trait>( self: Arc<Self>, identifier: Identifier, metadata_location: &'life0 str, ) -> Pin<Box<dyn Future<Output = Result<Table, IcebergError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Registers an existing table in the catalog using its metadata location.

impl Debug for SqlCatalog

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

Formats the value using the given formatter.