Skip to main content

events_to_record_batch

laminar_connectors::cdc::postgres::changelog

Function events_to_record_batch 

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

Converts a batch of ChangeEvents into an Arrow [RecordBatch] using the CDC envelope schema.

ยงErrors

Returns an error if the Arrow batch construction fails.