Skip to main content

events_to_record_batch

Function events_to_record_batch 

Source
pub fn events_to_record_batch(
    events: &[ChangeEvent],
    table_info: &TableInfo,
) -> Result<RecordBatch, ArrowError>
Expand description

Converts change events to a RecordBatch with CDC metadata + row data.

ยงErrors

Returns error if schema conversion fails.