Struct IcebergStaticTableProvider

pub struct IcebergStaticTableProvider { /* private fields */ }

Static table provider for read-only snapshot access.

This provider holds a cached table instance and does not refresh metadata or support write operations. Use this for consistent analytical queries, time-travel scenarios, or when you want to avoid catalog overhead.

For catalog-backed tables with write support and automatic refresh, use IcebergTableProvider instead.

Implementations

impl IcebergStaticTableProvider

pub async fn try_new_from_table(table: Table) -> Result<Self>

Creates a static provider from a table instance.

Uses the table’s current snapshot for all queries. Does not support write operations.

pub async fn try_new_from_table_snapshot( table: Table, snapshot_id: i64, ) -> Result<Self>

Creates a static provider for a specific table snapshot.

Queries the specified snapshot for all operations. Useful for time-travel queries. Does not support write operations.

Trait Implementations

impl Clone for IcebergStaticTableProvider

fn clone(&self) -> IcebergStaticTableProvider

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for IcebergStaticTableProvider

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

Formats the value using the given formatter.

impl TableProvider for IcebergStaticTableProvider

fn as_any(&self) -> &dyn Any

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

fn schema(&self) -> ArrowSchemaRef

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 = DFResult<Arc<dyn ExecutionPlan>>> + Send + 'async_trait>>

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

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

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

Specify if DataFusion should provide filter expressions to the TableProvider to apply during the scan.

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 = DFResult<Arc<dyn ExecutionPlan>>> + Send + 'async_trait>>

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

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

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 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.