Skip to main content

inc_dedup_view_sql

Function inc_dedup_view_sql 

Source
pub fn inc_dedup_view_sql(
    warehouse: Warehouse,
    view_fqtn: &str,
    changes_fqtn: &str,
    pk: &[&str],
    cursor_column: &str,
) -> String
Expand description

Build the current-state dedup view for an incremental load’s change log. Unlike CDC (dedup_view_sql), an incremental delta has no __op/__pos/ __seq (the change log reuses the CDC append so those columns exist but are NULL): current state is simply the row with the greatest cursor_column per PK. Incremental can’t observe deletes, so DELETE_FLAG_COLUMN is a constant FALSE — the view SHAPE matches CDC so downstream reads WHERE NOT __is_deleted uniformly across both modes.