Struct datafusion_python::common::schema::SqlTableSource

pub struct SqlTableSource { /* private fields */ }

SqlTable wrapper that is compatible with DataFusion logical query plans

Implementations

impl SqlTableSource

pub fn new( schema: SchemaRef, statistics: Option<SqlStatistics>, filepaths: Option<Vec<String>>, ) -> Self

Initialize a new EmptyTable from a schema

pub fn statistics(&self) -> Option<&SqlStatistics>

Access optional statistics associated with this table source

pub fn filepaths(&self) -> Option<&Vec<String>>

Access optional filepath associated with this table source

Trait Implementations

impl TableSource for SqlTableSource

Implement TableSource, used in the logical query plan and in logical query optimizations

fn as_any(&self) -> &dyn Any

fn schema(&self) -> SchemaRef

Get a reference to the schema for this table

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

👎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 table_type(&self) -> TableType

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

fn supports_filters_pushdown( &self, filters: &[&Expr], ) -> Result<Vec<TableProviderFilterPushDown>>

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 constraints(&self) -> Option<&Constraints>

Get primary key indices, if one exists.

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

Get the default value for a column, if available.