pub struct CatalogClient { /* private fields */ }Available on crate feature
catalog only.Expand description
Unity catalog client.
Implementations§
Source§impl CatalogClient
impl CatalogClient
pub async fn list_catalogs(&self) -> PolarsResult<Vec<CatalogInfo>>
pub async fn list_namespaces( &self, catalog_name: &str, ) -> PolarsResult<Vec<NamespaceInfo>>
pub async fn list_tables( &self, catalog_name: &str, namespace: &str, ) -> PolarsResult<Vec<TableInfo>>
pub async fn get_table_info( &self, catalog_name: &str, namespace: &str, table_name: &str, ) -> PolarsResult<TableInfo>
pub async fn get_table_credentials( &self, table_id: &str, write: bool, ) -> PolarsResult<TableCredentials>
pub async fn create_catalog( &self, catalog_name: &str, comment: Option<&str>, storage_root: Option<&str>, ) -> PolarsResult<CatalogInfo>
pub async fn delete_catalog( &self, catalog_name: &str, force: bool, ) -> PolarsResult<()>
pub async fn create_namespace( &self, catalog_name: &str, namespace: &str, comment: Option<&str>, storage_root: Option<&str>, ) -> PolarsResult<NamespaceInfo>
pub async fn delete_namespace( &self, catalog_name: &str, namespace: &str, force: bool, ) -> PolarsResult<()>
Sourcepub async fn create_table(
&self,
catalog_name: &str,
namespace: &str,
table_name: &str,
schema: Option<&Schema>,
table_type: &TableType,
data_source_format: Option<&DataSourceFormat>,
comment: Option<&str>,
storage_location: Option<&str>,
properties: &mut (dyn Iterator<Item = (&str, &str)> + Send + Sync),
) -> PolarsResult<TableInfo>
pub async fn create_table( &self, catalog_name: &str, namespace: &str, table_name: &str, schema: Option<&Schema>, table_type: &TableType, data_source_format: Option<&DataSourceFormat>, comment: Option<&str>, storage_location: Option<&str>, properties: &mut (dyn Iterator<Item = (&str, &str)> + Send + Sync), ) -> PolarsResult<TableInfo>
Note, data_source_format can be None for some table_types.
pub async fn delete_table( &self, catalog_name: &str, namespace: &str, table_name: &str, ) -> PolarsResult<()>
Auto Trait Implementations§
impl Freeze for CatalogClient
impl !RefUnwindSafe for CatalogClient
impl Send for CatalogClient
impl Sync for CatalogClient
impl Unpin for CatalogClient
impl UnsafeUnpin for CatalogClient
impl !UnwindSafe for CatalogClient
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more