risingwave_connector::sink::encoder::avro

Function validate_fields

source
fn validate_fields<'rw>(
    rw_fields: impl Iterator<Item = (&'rw str, &'rw DataType)>,
    avro: &Schema,
) -> Result<(), FieldEncodeError>