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.