pyflink.common.serialization.AvroRowDeserializationSchema

class AvroRowDeserializationSchema(record_class: Optional[str] = None, avro_schema_string: Optional[str] = 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.