risingwave_connector::sink::formatter::debezium_json

Function fields_pk_to_json

source 
pub(crate) fn fields_pk_to_json(fields: &[Field], pk_indices: &[usize]) -> Value