Enum FileWriter 

pub enum FileWriter {
    V2_0(Box<Writer>),
    V2_1(Box<Writer>),
    V2_2(Box<Writer>),
    V2_3(Box<Writer>),
}

A type-erased current-format file writer.

This enum exists for callers that select a concrete file version at runtime. Each variant owns the complete implementation for exactly one file grammar; this type only forwards operations without adding format policy.

Variants

V2_0(Box<Writer>)

V2_1(Box<Writer>)

V2_2(Box<Writer>)

V2_3(Box<Writer>)

Implementations

impl FileWriter

pub fn with_page_metadata_spill( self, object_store: Arc<ObjectStore>, path: Path, ) -> Self

Spill page metadata to a sidecar file.

pub async fn write_batches( &mut self, batches: impl Iterator<Item = &RecordBatch>, ) -> Result<()>

Schedule batches of data to be written to the file.

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

Schedule a batch of data to be written to the file.

pub async fn write_column( &mut self, column_index: usize, array: ArrayRef, ) -> Result<()>

Write one top-level column.

pub async fn write_external_buffer( &mut self, bytes: &[u8], ) -> Result<(u64, u64)>

Append a buffer whose page or column metadata is supplied externally.

pub fn add_schema_metadata( &mut self, key: impl Into<String>, value: impl Into<String>, )

Add a metadata entry to the schema.

pub fn initialize_with_external_columns( &mut self, schema: Schema, columns: &[Arc<ColumnInfo>], rows_written: u64, ) -> Result<()>

Prepare a writer from encoded columns whose buffers were produced externally.

pub async fn add_global_buffer(&mut self, buffer: Bytes) -> Result<u32>

Add an arbitrary global buffer and return its one-based index.

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

Finish the file and close its object writer.

pub async fn abort(&mut self)

Abandon the file write.

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

Return the current object-writer position.

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

Return the field-id to physical-column mapping.

Trait Implementations

impl From<Writer> for FileWriter

fn from(writer: Writer) -> Self

Converts to this type from the input type.

impl From<Writer> for FileWriter

fn from(writer: Writer) -> Self

Converts to this type from the input type.

impl From<Writer> for FileWriter

fn from(writer: Writer) -> Self

Converts to this type from the input type.

impl From<Writer> for FileWriter

fn from(writer: Writer) -> Self

Converts to this type from the input type.