Struct DeltaTableReader 

pub struct DeltaTableReader { /* private fields */ }

Reader for Delta Lake tables, supporting time travel and partition pruning.

Implementations

impl DeltaTableReader

pub fn new(config: DeltaConfig) -> Result<Self, DeltaError>

Create a new reader for the table at config.base_path.

pub fn read(&self, version: Option<u64>) -> Result<Vec<Vec<f64>>, DeltaError>

Read data from the table, optionally at a specific version (time travel).

Returns columnar data as Vec<Vec<f64>>.

pub fn read_pruned( &self, version: Option<u64>, partitions: &HashMap<String, String>, ) -> Result<Vec<Vec<f64>>, DeltaError>

Read data with partition pruning.

Only reads files whose partition values match the given predicates. partitions maps column name -> required value.

pub fn history(&self) -> Result<Vec<DeltaVersion>, DeltaError>

List all versions (history) of the table.

pub fn latest_version(&self) -> Option<u64>

Get the latest version number.

pub fn table_state( &self, version: Option<u64>, ) -> Result<DeltaTable, DeltaError>

Reconstruct the full table state at a given version.

pub fn transaction_log(&self) -> &TransactionLog

Access the underlying transaction log.