risingwave_stream::executor::mview::materialize

Function should_handle_conflict

source 
fn should_handle_conflict(
    old_version_column: &Option<ScalarImpl>,
    new_version_column: &Option<ScalarImpl>,
) -> bool
Expand description

Determines whether pk conflict should be handled based on the version column of the new and old rows.

§Arguments

  • old_version_column: The version column value of the old row.
  • new_version_column: The version column value of the new row.

§Returns

A boolean value indicating whether a conflict should be handled.

If both the new row’s version column and the old row’s version column are Some, the function will return true if the new row’s version is greater than or equal to the old row’s version. If the new row’s version column is None and the old row’s version column is Some, do not handle pk conflict. If both the new row’s version column and the old row’s version column are None, should handle pk conflict.