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>, filepath: Option<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 filepath(&self) -> Option<&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.