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.