risingwave_connector::sink::encoder::avro

Function validate_fields

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