Struct datafusion::datasource::default_table_source::DefaultTableSource

pub struct DefaultTableSource {
    pub table_provider: Arc<dyn TableProvider>,
}

DataFusion default table source, wrapping TableProvider

This structure adapts a TableProvider (physical plan trait) to the TableSource (logical plan trait)

Fields

table_provider: Arc<dyn TableProvider>

table provider

Implementations

impl DefaultTableSource

pub fn new(table_provider: Arc<dyn TableProvider>) -> Self

Create a new DefaultTableSource to wrap a TableProvider

Trait Implementations

impl TableSource for DefaultTableSource

fn as_any(&self) -> &dyn Any

Returns the table source as Any so that it can be downcast to a specific implementation.

fn schema(&self) -> SchemaRef

Get a reference to the schema for this table

fn supports_filters_pushdown( &self, filter: &[&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 table_type(&self) -> TableType

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

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.