Struct lance_file::v2::writer::FileWriter

pub struct FileWriter { /* private fields */ }

Implementations

impl FileWriter

pub fn try_new( object_writer: ObjectWriter, path: String, schema: LanceSchema, options: FileWriterOptions ) -> Result<Self>

Create a new FileWriter

pub async fn write_batch(&mut self, batch: &RecordBatch) -> Result<()>

Schedule a batch of data to be written to the file

Note: the future returned by this method may complete before the data has been fully flushed to the file (some data may be in the data cache or the I/O cache)

pub async fn finish(&mut self) -> Result<u64>

Finishes writing the file

This method will wait until all data has been flushed to the file. Then it will write the file metadata and the footer. It will not return until all data has been flushed and the file has been closed.

Returns the total number of rows written

pub fn multipart_id(&self) -> &str

pub async fn tell(&mut self) -> Result<u64>

pub fn field_id_to_column_indices(&self) -> &[(i32, i32)]

pub fn path(&self) -> &str