risingwave_connector::sink::postgres

Function convert_row_to_pg_row

Source 
fn convert_row_to_pg_row(
    row: impl Row,
    schema_types: &[Type],
) -> Vec<Option<ScalarAdapter>>