Struct DeltaWriterBuilder 

pub struct DeltaWriterBuilder<DWB, PDWB, EDWB> { /* private fields */ }

A builder for DeltaWriter.

Implementations

impl<DWB, PDWB, EDWB> DeltaWriterBuilder<DWB, PDWB, EDWB>

pub fn new( data_writer_builder: DWB, pos_delete_writer_builder: PDWB, eq_delete_writer_builder: EDWB, unique_cols: Vec<i32>, ) -> Self

Creates a new DeltaWriterBuilder.

pub fn with_max_seen_rows(self, max_seen_rows: usize) -> Self

Sets the maximum number of rows to track for position deletes.

When this limit is reached, the oldest tracked rows are evicted. Deletes for evicted rows will use equality deletes instead of position deletes. Default is DEFAULT_MAX_SEEN_ROWS.

Set to 0 to disable row tracking entirely, causing all deletes to use equality deletes. This eliminates memory overhead but may reduce read performance.

Trait Implementations

impl<DWB: Clone, PDWB: Clone, EDWB: Clone> Clone for DeltaWriterBuilder<DWB, PDWB, EDWB>

fn clone(&self) -> DeltaWriterBuilder<DWB, PDWB, EDWB>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<DWB: Debug, PDWB: Debug, EDWB: Debug> Debug for DeltaWriterBuilder<DWB, PDWB, EDWB>

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

Formats the value using the given formatter.

impl<DWB, PDWB, EDWB> IcebergWriterBuilder for DeltaWriterBuilder<DWB, PDWB, EDWB>

where DWB: IcebergWriterBuilder, PDWB: IcebergWriterBuilder, EDWB: IcebergWriterBuilder, DWB::R: CurrentFileStatus,

type R = DeltaWriter<<DWB as IcebergWriterBuilder>::R, <PDWB as IcebergWriterBuilder>::R, <EDWB as IcebergWriterBuilder>::R>

The associated writer type.

fn build<'life0, 'async_trait>( &'life0 self, partition_key: Option<PartitionKey>, ) -> Pin<Box<dyn Future<Output = Result<Self::R>> + Send + 'async_trait>>

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

Build the iceberg writer with an optional partition key.