Trait iceberg::writer::file_writer::FileWriter

source · 
pub trait FileWriter<O = Vec<DataFileBuilder>>: Send + CurrentFileStatus + 'static {
    // Required methods
    fn write(
        &mut self,
        batch: &RecordBatch,
    ) -> impl Future<Output = Result<()>> + Send;
    fn close(self) -> impl Future<Output = Result<O>> + Send;
}
Expand description

File writer focus on writing record batch to different physical file format.(Such as parquet. orc)

Required Methods§

source

fn write( &mut self, batch: &RecordBatch, ) -> impl Future<Output = Result<()>> + Send

Write record batch to file.

source

fn close(self) -> impl Future<Output = Result<O>> + Send

Close file writer.

Object Safety§

This trait is not object safe.

Implementors§