row_below_committed_watermark

risingwave_stream::executor::mview::cache

Function row_below_committed_watermark 

Source 
fn row_below_committed_watermark<S: StateStore, SD: ValueRowSerde>(
    row_serde: &BasicSerde,
    table: &StateTableInner<S, SD>,
    row: &CompactedRow,
) -> StreamExecutorResult<bool>
Expand description

Check whether the given row is below the committed watermark. If so, we may want to treat them as non-existent. This extra step is necessary for TTL-ed tables because:

  • the storage may clean expired rows asynchronously
  • an expired row may still be in the cache while we expect a consistent view