Struct SnapshotTransaction 

pub struct SnapshotTransaction {
    pub adds: Vec<IcebergDataFile>,
    pub removes: Vec<String>,
    pub dvs: HashMap<String, DeletionVector>,
    pub props: HashMap<String, String>,
}

Describes a single atomic change to the Iceberg table state.

After building, pass to IcebergCatalog::commit_transaction() to:

1. Add new DataFile entries for adds.
2. Remove DataFile entries for removes.
3. Upload merged .puffin files for dvs and attach to existing DataFile.
4. Commit the Iceberg snapshot with summary props.

Fields

adds: Vec<IcebergDataFile>

New Parquet files produced by this flush/compaction.

removes: Vec<String>

Paths of fully-compacted files to remove from the manifest. A file is removable when dv.cardinality() == file.num_rows.

dvs: HashMap<String, DeletionVector>

Partial-compaction DV updates. Key = Parquet file path. The DV here is the additional set of row positions to mark deleted. The commit path must union_with() any pre-existing DV before uploading.

props: HashMap<String, String>

Snapshot summary properties (e.g. "merutable.job" = "flush").

Implementations

impl SnapshotTransaction

pub fn new() -> Self

Create an empty transaction.

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

Add a newly written Parquet file to the transaction.

pub fn remove_file(&mut self, path: String)

Mark a file path for removal from the manifest (fully compacted).

pub fn add_dv(&mut self, path: String, dv: DeletionVector)

Record additional deleted row positions for a Parquet file. If the file already has pending DV changes in this transaction, merge.

pub fn set_prop(&mut self, key: impl Into<String>, value: impl Into<String>)

Set a snapshot summary property.

pub fn is_empty(&self) -> bool

True if this transaction makes no changes.

pub fn num_adds(&self) -> usize

Total number of new files being added.

pub fn num_removes(&self) -> usize

Total number of files being removed.

Trait Implementations

impl Clone for SnapshotTransaction

fn clone(&self) -> SnapshotTransaction

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SnapshotTransaction

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

Formats the value using the given formatter.

impl Default for SnapshotTransaction

fn default() -> Self

Returns the “default value” for a type.