pyflink.datastream.formats.avro.AvroSchema

class AvroSchema(j_schema)

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.