Struct PositionDeleteFileWriter 

pub struct PositionDeleteFileWriter<B: FileWriterBuilder, L: LocationGenerator, F: FileNameGenerator> { /* private fields */ }

Writer used to write position delete files within one spec/partition.

Trait Implementations

impl<B: Debug + FileWriterBuilder, L: Debug + LocationGenerator, F: Debug + FileNameGenerator> Debug for PositionDeleteFileWriter<B, L, F>

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

Formats the value using the given formatter.

impl<B, L, F> IcebergWriter for PositionDeleteFileWriter<B, L, F>

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

fn write<'life0, 'async_trait>( &'life0 mut self, batch: RecordBatch, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Writes a batch of (file_path, pos) records; the shape is validated on every call.

The writer does not sort its input. Position delete files must be sorted by file_path then pos, so the caller must supply rows in that order across all write calls; a sorting writer will remove this requirement.

fn close<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Vec<DataFile>>> + Send + 'async_trait>>

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

Close the writer and return the written data files. If close failed, the data written before maybe be lost. User may need to recreate the writer and rewrite the data again.