pyflink.datastream.formats.parquet.AvroParquetReaders

class AvroParquetReaders

A convenience builder to create reader format that reads individual Avro records from a Parquet stream. Only GenericRecord is supported in PyFlink.

Added in version 1.16.0.

Methods

for_generic_record(schema)

Creates a new AvroParquetRecordFormat that reads the parquet file into Avro GenericRecords.