pyflink.datastream.formats.avro.AvroRowDeserializationSchema

class AvroRowDeserializationSchema(record_class: str | None = None, avro_schema_string: str | None = None)

Deserialization schema from Avro bytes to Row. Deserializes the byte[] messages into (nested) Flink rows. It converts Avro types into types that are compatible with Flink’s Table & SQL API.

Projects with Avro records containing logical date/time types need to add a JodaTime dependency.