Struct ArrowBatchBuilder 

pub struct ArrowBatchBuilder { /* private fields */ }

Incremental Arrow RecordBatch builder.

Rows are pushed one at a time via push_row. Call finish to produce a RecordBatch and reset the builder.

The builder validates that each row’s length matches the schema.

Implementations

impl ArrowBatchBuilder

pub fn new(schema: SchemaRef) -> Result<Self, ArrowError>

Create a new builder for the given schema.

Returns an error if the schema contains unsupported data types.

pub fn schema(&self) -> &SchemaRef

The schema this builder produces.

pub fn len(&self) -> usize

Number of rows appended since the last finish.

pub fn is_empty(&self) -> bool

Returns true if no rows have been appended.

pub fn push_row(&mut self, values: &[ArrowValue]) -> Result<(), ArrowError>

Append a row of values.

Returns ArrowError::SchemaError if the row length doesn’t match the schema, or if a value type doesn’t match its column’s data type.

pub fn finish(&mut self) -> Result<RecordBatch, ArrowError>

Consume the accumulated rows and produce a RecordBatch.

The builder is reset and can be reused for the next batch.