Trait iceberg::writer::IcebergWriterBuilder

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

    // Required method
    fn build<'async_trait>(
        self,
        config: Self::C,
    ) -> Pin<Box<dyn Future<Output = Result<Self::R>> + Send + 'async_trait>>
       where Self: 'async_trait;
}

The builder for iceberg writer.

Required Associated Types

type R: IcebergWriter<I, O>

The associated writer type.

type C

The associated writer config type used to build the writer.

Required Methods

fn build<'async_trait>( self, config: Self::C, ) -> Pin<Box<dyn Future<Output = Result<Self::R>> + Send + 'async_trait>>

where Self: 'async_trait,

Build the iceberg writer.

Object Safety

This trait is not object safe.

Implementors

impl<B: FileWriterBuilder> IcebergWriterBuilder for DataFileWriterBuilder<B>

type R = DataFileWriter<B>

type C = DataFileWriterConfig