pyflink.datastream.formats.avro.AvroRowSerializationSchema

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

Serialization schema that serializes to Avro binary format.