Trait IcebergWriter 

pub trait IcebergWriter: Send + 'static {
    // Required methods
    fn write_chunk<'life0, 'async_trait>(
        &'life0 mut self,
        chunk: DataChunk,
    ) -> Pin<Box<dyn Future<Output = StreamExecutorResult<Vec<PositionDeleteInput>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn flush<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = StreamExecutorResult<Option<SinkMetadata>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Trait abstracting the Iceberg data file writing for testability.

Implementations are responsible for writing rows to Iceberg data files and tracking row positions. Commit is handled by the executor, not the writer.

Required Methods

fn write_chunk<'life0, 'async_trait>( &'life0 mut self, chunk: DataChunk, ) -> Pin<Box<dyn Future<Output = StreamExecutorResult<Vec<PositionDeleteInput>>> + Send + 'async_trait>>

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

Write a batch of insert rows. Returns the position of each row in the chunk (in order).

fn flush<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = StreamExecutorResult<Option<SinkMetadata>>> + Send + 'async_trait>>

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

Flush current data files on barrier. Returns serialized commit metadata, or None if no data was written since the last flush.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl IcebergWriter for IcebergWriterImpl