Struct RowBatchBridge 

pub struct RowBatchBridge { /* private fields */ }

Accumulates EventRows into Arrow RecordBatch for Ring 0 → Ring 1 handoff.

Each column is backed by an Arrow ArrayBuilder matching the field type. When the bridge is full (or explicitly flushed), the accumulated rows are materialized into a RecordBatch.

Implementations

impl RowBatchBridge

pub fn new(schema: SchemaRef, capacity: usize) -> Result<Self, BridgeError>

Creates a new bridge for the given Arrow schema with the specified row capacity.

Errors

Returns BridgeError::Schema if the schema contains unsupported data types.

pub fn append_row(&mut self, row: &EventRow<'_>) -> Result<(), BridgeError>

Decomposes the row’s fields into the column builders.

Errors

Returns BridgeError::Full if the bridge has reached capacity.

pub fn is_full(&self) -> bool

Returns true if the bridge has reached its row capacity.

pub fn flush(&mut self) -> RecordBatch

Finalizes all builders into a RecordBatch and resets the bridge.

Panics

Panics if the builders produce arrays incompatible with the schema (indicates a bug in the bridge, not user error).

pub fn row_count(&self) -> usize

Returns the number of rows currently accumulated.

pub fn capacity(&self) -> usize

Returns the row capacity.