Struct datafusion_federation::sql::SQLTableSource

pub struct SQLTableSource { /* private fields */ }

Implementations

impl SQLTableSource

pub async fn new( provider: Arc<SQLFederationProvider>, table_name: String, ) -> Result<Self>

pub fn new_with_schema( provider: Arc<SQLFederationProvider>, table_name: String, schema: SchemaRef, ) -> Result<Self>

pub fn table_name(&self) -> &str

Trait Implementations

impl FederatedTableSource for SQLTableSource

fn federation_provider(&self) -> Arc<dyn FederationProvider>

impl TableSource for SQLTableSource

fn as_any(&self) -> &dyn Any

fn schema(&self) -> SchemaRef

Get a reference to the schema for this table

fn table_type(&self) -> TableType

Get the type of this table for metadata/catalog purposes.

fn constraints(&self) -> Option<&Constraints>

Get primary key indices, if one exists.

fn supports_filter_pushdown( &self, _filter: &Expr, ) -> Result<TableProviderFilterPushDown, DataFusionError>

👎Deprecated since 20.0.0: use supports_filters_pushdown instead

Tests whether the table provider can make use of a filter expression to optimise data retrieval.

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 optimise data retrieval.

fn get_logical_plan(&self) -> Option<&LogicalPlan>

Get the Logical plan of this table provider, if available.

fn get_column_default(&self, _column: &str) -> Option<&Expr>

Get the default value for a column, if available.