Struct DeltaTableBuilder 

pub struct DeltaTableBuilder { /* private fields */ }

Configures and loads one immutable Delta table snapshot.

The asynchronous path uses the caller’s Tokio runtime. Scans return a pull-driven stream and do not materialize the whole table.

Example

use delta_arrow_reader::{DeltaComparison, DeltaPredicate, DeltaScalar, DeltaTableBuilder};
use futures_util::TryStreamExt;

let table = DeltaTableBuilder::new("/tmp/example-delta-table")
    .load_async()
    .await?;
let scan = table
    .scan()
    .with_projection(vec!["id".into(), "name".into()])
    .with_predicate(DeltaPredicate::Compare {
        column: "id".into(),
        op: DeltaComparison::GtEq,
        value: DeltaScalar::Int64(10),
    })
    .with_limit(100)
    .build()
    .await?;
let mut batches = scan.execute().await?;

while let Some(batch) = batches.try_next().await? {
    println!("rows={}", batch.num_rows());
}

Implementations

impl DeltaTableBuilder

pub fn new(table_uri: impl Into<String>) -> Self

Creates a builder for the latest snapshot with default execution settings.

pub fn with_storage_options(self, value: DeltaStorageOptions) -> Self

Replaces the storage options forwarded during table loading.

pub const fn with_snapshot_selection( self, value: DeltaSnapshotSelection, ) -> Self

Selects the Delta snapshot to load.

pub const fn with_execution_options( self, value: DeltaReaderExecutionOptions, ) -> Self

Replaces the default execution settings used by scans of this table.

pub fn load(self) -> Result<DeltaTable, DeltaReaderError>

Loads the snapshot on the calling thread.

pub async fn load_async(self) -> Result<DeltaTable, DeltaReaderError>

Loads the snapshot through the caller-owned Tokio runtime.

pub fn load_snapshot(self) -> Result<DeltaTableSnapshot, DeltaReaderError>

Loads snapshot metadata without converting its logical Arrow schema.

pub async fn load_snapshot_async( self, ) -> Result<DeltaTableSnapshot, DeltaReaderError>

Loads snapshot metadata through the caller-owned Tokio runtime.

Trait Implementations

impl Debug for DeltaTableBuilder

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

Formats the value using the given formatter.