risingwave_connector::parser::unified::debezium

Function extract_bson_id

source 
pub fn extract_bson_id(id_type: &DataType, bson_doc: &Value) -> AccessResult