pub struct SQLTableSource {
pub provider: Arc<SQLFederationProvider>,
pub table: Arc<dyn SQLTable>,
}
Fields§
§provider: Arc<SQLFederationProvider>
§table: Arc<dyn SQLTable>
Implementations§
Source§impl SQLTableSource
impl SQLTableSource
pub async fn new( provider: Arc<SQLFederationProvider>, table_ref: RemoteTableRef, ) -> Result<Self>
Sourcepub fn new_with_schema(
provider: Arc<SQLFederationProvider>,
table_ref: RemoteTableRef,
schema: SchemaRef,
) -> Self
pub fn new_with_schema( provider: Arc<SQLFederationProvider>, table_ref: RemoteTableRef, schema: SchemaRef, ) -> Self
Create a SQLTableSource with a table reference and schema
Sourcepub fn new_with_table(
provider: Arc<SQLFederationProvider>,
table: Arc<dyn SQLTable>,
) -> Self
pub fn new_with_table( provider: Arc<SQLFederationProvider>, table: Arc<dyn SQLTable>, ) -> Self
Create new with a custom SQLtable instance.
Sourcepub fn table_reference(&self) -> TableReference
pub fn table_reference(&self) -> TableReference
Return associated table reference of stored remote table
Trait Implementations§
Source§impl Clone for SQLTableSource
impl Clone for SQLTableSource
Source§fn clone(&self) -> SQLTableSource
fn clone(&self) -> SQLTableSource
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreSource§impl Debug for SQLTableSource
impl Debug for SQLTableSource
Source§impl FederatedTableSource for SQLTableSource
impl FederatedTableSource for SQLTableSource
fn federation_provider(&self) -> Arc<dyn FederationProvider>
Source§impl TableSource for SQLTableSource
impl TableSource for SQLTableSource
fn as_any(&self) -> &dyn Any
Source§fn table_type(&self) -> TableType
fn table_type(&self) -> TableType
Get the type of this table for metadata/catalog purposes.
Source§fn constraints(&self) -> Option<&Constraints>
fn constraints(&self) -> Option<&Constraints>
Get primary key indices, if any
Source§fn supports_filters_pushdown(
&self,
filters: &[&Expr],
) -> Result<Vec<TableProviderFilterPushDown>, DataFusionError>
fn supports_filters_pushdown( &self, filters: &[&Expr], ) -> Result<Vec<TableProviderFilterPushDown>, DataFusionError>
Tests whether the table provider can make use of any or all filter expressions
to optimize data retrieval. Only non-volatile expressions are passed to this function.
Source§fn get_logical_plan(&self) -> Option<Cow<'_, LogicalPlan>>
fn get_logical_plan(&self) -> Option<Cow<'_, LogicalPlan>>
Get the Logical plan of this table provider, if available. Read more
Auto Trait Implementations§
impl Freeze for SQLTableSource
impl !RefUnwindSafe for SQLTableSource
impl Send for SQLTableSource
impl Sync for SQLTableSource
impl Unpin for SQLTableSource
impl !UnwindSafe for SQLTableSource
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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