Struct MaterializedView 

pub struct MaterializedView { /* private fields */ }

A DataFusion TableProvider for materialized views.

Implementations

impl MaterializedView

pub fn new( lakehouse: Arc<LakehouseContext>, reader_factory: Arc<ReaderFactory>, view: Arc<dyn View>, part_provider: Arc<dyn QueryPartitionProvider>, query_range: Option<TimeRange>, instance_guard: Option<Arc<AudienceGuard>>, ) -> MaterializedView

pub fn get_view(&self) -> Arc<dyn View>

pub fn instance_is_audience_guarded(&self) -> bool

Whether AudienceGuard::authorize_view_instance will resolve this view’s instance id against the caller’s scope, and deny, before scan yields a row. True only for a caller-named, non-'global' view_instance(...): those take the guard’s Uuid arm (or its fail-closed fallthrough). 'global' is excluded because the guard passes it unconditionally – global instances are row-filtered instead.

Deliberately does not mirror the guard’s public-view-set arm: this accessor would still return true for a public view set’s instance, even though the guard passes it unconditionally before ever reaching the Uuid arm. Harmless – OwnershipRewrite::predicate_for’s own public-view-set check already returns Ok(None) before this accessor is ever consulted, and both checks read IsolationConfig::public_view_sets.

Kept in step with AudienceGuard::authorize_view_instance’s arms; changing those means revisiting this.

Trait Implementations

impl Debug for MaterializedView

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl TableProvider for MaterializedView

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

Tell DataFusion to push filters down to the scan method

fn schema(&self) -> Arc<Schema>

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 scan<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, state: &'life1 dyn Session, projection: Option<&'life2 Vec<usize>>, filters: &'life3 [Expr], limit: Option<usize>, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn ExecutionPlan>, DataFusionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, MaterializedView: 'async_trait,

Create an [ExecutionPlan] for scanning the table with optional projection, filter, and limit, described below.

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

Get a reference to the constraints of the table. Returns:

fn get_table_definition(&self) -> Option<&str>

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

fn get_logical_plan(&self) -> Option<Cow<'_, LogicalPlan>>

Get the [LogicalPlan] of this table, if available.

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

Get the default value for a column, if available.

fn scan_with_args<'a, 'life0, 'life1, 'async_trait>( &'life0 self, state: &'life1 dyn Session, args: ScanArgs<'a>, ) -> Pin<Box<dyn Future<Output = Result<ScanResult, DataFusionError>> + Send + 'async_trait>>

where 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Create an [ExecutionPlan] for scanning the table using structured arguments.

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

Get statistics for this table, if available Although not presently used in mainline DataFusion, this allows implementation specific behavior for downstream repositories, in conjunction with specialized optimizer rules to perform operations such as re-ordering of joins.

fn insert_into<'life0, 'life1, 'async_trait>( &'life0 self, _state: &'life1 dyn Session, _input: Arc<dyn ExecutionPlan>, _insert_op: InsertOp, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn ExecutionPlan>, DataFusionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Return an [ExecutionPlan] to insert data into this table, if supported.

fn delete_from<'life0, 'life1, 'async_trait>( &'life0 self, _state: &'life1 dyn Session, _filters: Vec<Expr>, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn ExecutionPlan>, DataFusionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Delete rows matching the filter predicates.

fn update<'life0, 'life1, 'async_trait>( &'life0 self, _state: &'life1 dyn Session, _assignments: Vec<(String, Expr)>, _filters: Vec<Expr>, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn ExecutionPlan>, DataFusionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Update rows matching the filter predicates.

fn truncate<'life0, 'life1, 'async_trait>( &'life0 self, _state: &'life1 dyn Session, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn ExecutionPlan>, DataFusionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Remove all rows from the table.

fn merge_into<'life0, 'life1, 'async_trait>( &'life0 self, _state: &'life1 dyn Session, _source: Arc<dyn ExecutionPlan>, _merge_schema: Arc<DFSchema>, _on: Expr, _clauses: Vec<MergeIntoClause>, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn ExecutionPlan>, DataFusionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Merge rows from a source into this table.