extract_bson_id

risingwave_connector::parser::unified::debezium

Function extract_bson_id 

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