Struct datafusion::datasource::view::ViewTable

pub struct ViewTable { /* private fields */ }

An implementation of TableProvider that uses another logical plan.

Implementations

impl ViewTable

pub fn try_new(
    logical_plan: LogicalPlan,
    definition: Option<String>
) -> Result<Self>

Create new view that is executed at query runtime. Takes a LogicalPlan and an optional create statement as input.

pub fn definition(&self) -> &Option<String>

Get definition ref

pub fn logical_plan(&self) -> &LogicalPlan

Get logical_plan ref

Trait Implementations

impl TableProvider for ViewTable

fn as_any(&self) -> &dyn Any

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

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

Get the Logical Plan of this table, if available.

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 get_table_definition(&self) -> Option<&str>

Get the create statement used to create this table, if available.

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

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

fn scan<'life0, 'life1, 'life2, 'life3, 'async_trait>(
    &'life0 self,
    state: &'life1 SessionState,
    projection: &'life2 Option<Vec<usize>>,
    filters: &'life3 [Expr],
    limit: Option<usize>
) -> Pin<Box<dyn Future<Output = Result<Arc<dyn ExecutionPlan>>> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    'life3: 'async_trait,
    Self: 'async_trait,

Create an ExecutionPlan that will scan the table. The table provider will be usually responsible of grouping the source data into partitions that can be efficiently parallelized or distributed.

fn statistics(&self) -> Option<Statistics>

Get statistics for this table, if available