risingwave_connector::sink::postgres

Function create_delete_sql

source
fn create_delete_sql(
    schema: &Schema,
    table_name: &str,
    pk_indices: &[usize],
    number_of_rows: usize,
) -> String