pyflink.datastream.formats.avro.AvroBulkWriters#

class AvroBulkWriters[source]#

Convenience builder to create BulkWriterFactory for Avro types.

New in version 1.16.0.

Methods

for_generic_record(schema)

Creates an AvroWriterFactory that accepts and writes Avro generic types.