pyflink.datastream.formats.parquet.AvroParquetWriters# class AvroParquetWriters[source]# Convenient builder to create Parquet BulkWriterFactory instances for Avro types. Only GenericRecord is supported at present. New in version 1.16.0. Methods for_generic_record(schema) Creates a ParquetWriterFactory that accepts and writes Avro generic types.