risingwave_connector::parser::util

Function extract_cdc_meta_column

source
pub fn extract_cdc_meta_column<'a>(
    cdc_meta: &'a DebeziumCdcMeta,
    column_type: &ColumnType,
    column_name: &str,
) -> AccessResult<DatumRef<'a>>