pyflink.datastream.formats.avro.AvroSchema# class AvroSchema(j_schema)[source]# Avro Schema class contains Java org.apache.avro.Schema. New in version 1.16.0. Methods parse_file(file_path) Parse a schema definition file as Avro Schema. parse_string(json_schema) Parse JSON string as Avro Schema.