Struct RecordBatchBuilder 

pub struct RecordBatchBuilder { /* private fields */ }

Builds Arrow RecordBatch objects from a stream of raw COBOL records.

Implementations

impl RecordBatchBuilder

pub fn new( arrow_schema: Arc<ArrowSchema>, cobol_schema: &Schema, options: &ArrowOptions, ) -> Result<Self>

Create a new builder.

Errors

Returns an error if accumulator creation fails for any field.

pub fn append_record(&mut self, record: &[u8]) -> Result<Option<RecordBatch>>

Append a raw record. Returns Some(batch) when batch_size is reached.

Errors

Returns an error if decoding or batch construction fails.

pub fn flush(&mut self) -> Result<Option<RecordBatch>>

Flush remaining records as a partial batch (may be empty).

Errors

Returns an error if batch construction fails.