Skip to main content

unique_aborted_transaction_rows

Function unique_aborted_transaction_rows 

Source
pub fn unique_aborted_transaction_rows(rows: &[(i64, i64)]) -> Vec<(i64, i64)>
Expand description

Preserve every distinct wire (producer_id, first_offset) row exactly once. The caller has already selected the overlapping transactions.