Skip to main content

apply_change_to_slot

risingwave_stream::executor::locality_provider

Function apply_change_to_slot 

Source 
fn apply_change_to_slot(
    slot: &mut Option<Record<OwnedRow>>,
    is_insert: bool,
    row: OwnedRow,
)
Expand description

Apply one buffered change to the per-key compaction slot, mirroring the semantics of ChangeBuffer: consecutive changes of the same key are merged into at most one record.