risingwave_stream::executor::mview::materialize

Function version_is_newer_or_equal

Source 
fn version_is_newer_or_equal(
    old_version: &Option<ScalarImpl>,
    new_version: &Option<ScalarImpl>,
) -> bool
Expand description

Determines whether pk conflict handling should update an existing row with newly-received value, according to the value of version column of the new and old rows.