Struct RowDeltaAction 

pub struct RowDeltaAction { /* private fields */ }

RowDeltaAction is a transaction action for encoding row-level changes to a table.

This action supports:

• Adding new data files
• Adding delete files (both position and equality deletes)

This is the appropriate action to use for:

• CDC (Change Data Capture) ingestion
• Upsert operations
• Row-level deletions

Example

use iceberg::transaction::Transaction;

let tx = Transaction::new(&table);
let action = tx.row_delta()
    .add_data_files(new_data_files)
    .add_delete_files(equality_delete_files);
let tx = action.apply(tx).unwrap();
let table = tx.commit(&catalog).await.unwrap();

Implementations

impl RowDeltaAction

pub fn new() -> Self

Create a new row delta action. Equivalent to crate::transaction::Transaction::row_delta.

pub fn with_check_duplicate(self, v: bool) -> Self

Set whether to check duplicate files

pub fn add_data_files( self, data_files: impl IntoIterator<Item = DataFile>, ) -> Self

Add data files to the snapshot.

pub fn add_delete_files( self, delete_files: impl IntoIterator<Item = DataFile>, ) -> Self

Add delete files to the snapshot.

Delete files can be either position deletes or equality deletes. The content type of each file will be validated.

pub fn set_commit_uuid(self, commit_uuid: Uuid) -> Self

Set commit UUID for the snapshot.

pub fn set_snapshot_properties( self, snapshot_properties: HashMap<String, String>, ) -> Self

Set snapshot summary properties.

Trait Implementations

impl Default for RowDeltaAction

fn default() -> Self

Returns the “default value” for a type.

impl TransactionAction for RowDeltaAction

fn commit<'life0, 'async_trait>( self: Arc<Self>, table: &'life0 Table, ) -> Pin<Box<dyn Future<Output = Result<ActionCommit>> + Send + 'async_trait>>

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

Commits this action against the provided table and returns the resulting updates. NOTE: Most users should apply actions through Transaction, which handles rebasing onto the latest table state and retrying on commit conflicts. Call this directly only to take over that responsibility yourself, passing the resulting updates and requirements to Catalog::update_table via TableCommit.