You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Haizhou Zhao <zh...@gmail.com> on 2022/02/22 22:54:38 UTC

Avro Flink Row Conversion

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