pyflink.datastream.formats.avro.AvroRowDeserializationSchema#
- class AvroRowDeserializationSchema(record_class: Optional[str] = None, avro_schema_string: Optional[str] = None)[source]#
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.