risingwave_connector::sink::encoder::json

Function datum_to_json_object

source 
fn datum_to_json_object(
    field: &Field,
    datum: DatumRef<'_>,
    config: &JsonEncoderConfig,
) -> ArrayResult<Value>