pyflink.datastream.formats.avro.AvroInputFormat#
- class AvroInputFormat(path: str, schema: pyflink.datastream.formats.avro.AvroSchema)[source]#
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
()