risingwave_connector::sink::encoder::avro

Function encode_fields

source 
fn encode_fields<'avro, 'rw>(
    fields_with_datums: impl Iterator<Item = ((&'rw str, &'rw DataType), DatumRef<'rw>)>,
    schema: &'avro Schema,
) -> Result<Record<'avro>, FieldEncodeError>