Skip to main content

postgres_row_to_owned_row_with_strict_pk

risingwave_connector::parser

Function postgres_row_to_owned_row_with_strict_pk 

Source 
pub fn postgres_row_to_owned_row_with_strict_pk(
    row: Row,
    schema: &Schema,
    pk_indices: &[usize],
) -> Result<OwnedRow>
Expand description

Decode primary-key columns strictly while preserving the legacy lenient behavior for all other columns in a PostgreSQL CDC snapshot row.