Hello Flink Community, I’m looking for an interface to convert Avro records to Flink row.
To be more specific, I’m aware there is this interface that converts serialized Avro records to Flink rows ( https://github.com/apache/flink/blob/master/flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java#L163), but the difference is that the interface above converts bytes -> Flink row, and I’m looking for Avro records -> Flink rows. Is there an existing interface/API that will fit my use case? Thank you, Haizhou
