Trait IcebergWriterBuilder

pub trait IcebergWriterBuilder<I = RecordBatch, O = Vec<DataFile>>:
    Send
    + Sync
    + 'static {
    type R: IcebergWriter<I, O>;

    // Required method
    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;
}

The builder for iceberg writer.

Required Associated Types

type R: IcebergWriter<I, O>

The associated writer type.

Required Methods

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.

Implementors

impl<B, L, F> IcebergWriterBuilder for DataFileWriterBuilder<B, L, F>

where B: FileWriterBuilder, L: LocationGenerator, F: FileNameGenerator,

type R = DataFileWriter<B, L, F>

impl<B, L, F> IcebergWriterBuilder for EqualityDeleteFileWriterBuilder<B, L, F>

where B: FileWriterBuilder, L: LocationGenerator, F: FileNameGenerator,

type R = EqualityDeleteFileWriter<B, L, F>