pyflink.datastream.formats.avro.AvroInputFormat

class AvroInputFormat(path: str, schema: AvroSchema)

Provides a FileInputFormat for Avro records.

Example:

>>> env = StreamExecutionEnvironment.get_execution_environment()
>>> schema = AvroSchema.parse_string(JSON_SCHEMA)
>>> ds = env.create_input(AvroInputFormat(FILE_PATH, schema))

New in version 1.16.0.

Methods

get_java_object()
get_produced_type()