risingwave_frontend::handler::util

Function to_pg_rows

source 
fn to_pg_rows(
    column_types: &[DataType],
    chunk: DataChunk,
    formats: &[Format],
    session_data: &StaticSessionData,
) -> Result<Vec<Row>, RwError>