Struct deltalake::data_catalog::unity::datafusion::UnitySchemaProvider
source · pub struct UnitySchemaProvider { /* private fields */ }
Expand description
A datafusion SchemaProvider
backed by Databricks UnityCatalog
Implementations§
source§impl UnitySchemaProvider
impl UnitySchemaProvider
sourcepub async fn try_new(
client: Arc<UnityCatalog>,
catalog_name: impl Into<String>,
schema_name: impl Into<String>,
storage_options: impl IntoIterator<Item = (impl Into<String>, impl Into<String>)>
) -> Result<UnitySchemaProvider, DataCatalogError>
pub async fn try_new( client: Arc<UnityCatalog>, catalog_name: impl Into<String>, schema_name: impl Into<String>, storage_options: impl IntoIterator<Item = (impl Into<String>, impl Into<String>)> ) -> Result<UnitySchemaProvider, DataCatalogError>
Create a new instance of UnitySchemaProvider
Trait Implementations§
source§impl SchemaProvider for UnitySchemaProvider
impl SchemaProvider for UnitySchemaProvider
source§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
Returns this
SchemaProvider
as Any
so that it can be downcast to a
specific implementation.source§fn table_names(&self) -> Vec<String>
fn table_names(&self) -> Vec<String>
Retrieves the list of available table names in this schema.
source§fn table<'life0, 'life1, 'async_trait>(
&'life0 self,
name: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<Option<Arc<dyn TableProvider>>, DataFusionError>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
UnitySchemaProvider: 'async_trait,
fn table<'life0, 'life1, 'async_trait>(
&'life0 self,
name: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<Option<Arc<dyn TableProvider>>, DataFusionError>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
UnitySchemaProvider: 'async_trait,
Retrieves a specific table from the schema by name, if it exists,
otherwise returns
None
.source§fn table_exist(&self, name: &str) -> bool
fn table_exist(&self, name: &str) -> bool
Returns true if table exist in the schema provider, false otherwise.
source§fn owner_name(&self) -> Option<&str>
fn owner_name(&self) -> Option<&str>
Returns the owner of the Schema, default is None. This value is reported
as part of `information_tables.schemata
source§fn register_table(
&self,
name: String,
table: Arc<dyn TableProvider>
) -> Result<Option<Arc<dyn TableProvider>>, DataFusionError>
fn register_table( &self, name: String, table: Arc<dyn TableProvider> ) -> Result<Option<Arc<dyn TableProvider>>, DataFusionError>
If supported by the implementation, adds a new table named
name
to
this schema. Read moresource§fn deregister_table(
&self,
name: &str
) -> Result<Option<Arc<dyn TableProvider>>, DataFusionError>
fn deregister_table( &self, name: &str ) -> Result<Option<Arc<dyn TableProvider>>, DataFusionError>
If supported by the implementation, removes the
name
table from this
schema and returns the previously registered TableProvider
, if any. Read moreAuto Trait Implementations§
impl Freeze for UnitySchemaProvider
impl !RefUnwindSafe for UnitySchemaProvider
impl Send for UnitySchemaProvider
impl Sync for UnitySchemaProvider
impl Unpin for UnitySchemaProvider
impl !UnwindSafe for UnitySchemaProvider
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
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§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 moreCreates a shared type from an unshared type.