Struct Transaction 

pub struct Transaction { /* private fields */ }

A transaction represents a unit of work against a table.

Transactions track:

• The base state (snapshot) at transaction start
• Files to be added
• Files to be deleted
• Schema changes (if any)

At commit time, the transaction validates that no conflicting changes have been made and atomically updates the table metadata.

Implementations

impl Transaction

pub fn new(metadata: TableMetadata) -> Self

Creates a new transaction based on the current table state.

pub fn with_operation(self, operation: Operation) -> Self

Sets the operation type.

pub fn with_isolation_level(self, level: IsolationLevel) -> Self

Sets the isolation level.

pub fn with_retry_config(self, config: RetryConfig) -> Self

Sets the retry configuration.

pub fn add_files(&mut self, files: impl IntoIterator<Item = DataFile>)

Adds data files to be committed.

pub fn add_file(&mut self, file: DataFile)

Adds a single data file to be committed.

pub fn delete_files(&mut self, paths: impl IntoIterator<Item = String>)

Marks files for deletion.

pub fn delete_file(&mut self, path: impl Into<String>)

Marks a single file for deletion.

pub fn set_schema(&mut self, schema: Schema)

Sets a new schema to be applied.

pub fn with_summary_property( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

Adds a custom summary property.

pub fn has_changes(&self) -> bool

Returns true if this transaction has changes to commit.

pub fn added_files_count(&self) -> usize

Returns the number of files to be added.

pub fn deleted_files_count(&self) -> usize

Returns the number of files to be deleted.

pub fn added_records_count(&self) -> i64

Returns the total records to be added.

pub async fn commit( self, catalog: Arc<dyn Catalog>, ) -> TransactionResult<Snapshot>

Commits the transaction to the catalog.

pub fn prepare_commit(&self) -> TransactionResult<PreparedCommit>

Prepares the transaction for commit.

This method:

1. Validates the transaction
2. Builds manifest files for new data
3. Creates the new snapshot
4. Returns the updated metadata ready for atomic commit

Trait Implementations

impl Debug for Transaction

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

Formats the value using the given formatter.