Skip to main content

op_to_code

risingwave_stream::executor::locality_provider

Function op_to_code 

Source 
fn op_to_code(op: Op) -> i16
Expand description

Op code of a buffered change, stored in the _rw_op column of the sort buffer table. Update ops are normalized to Insert/Delete on write (see Op::normalize_update), and reconstructed as Update records by per-key compaction on replay.