Package org.apache.flink.formats.avro

Class AvroWriterFactory<T>

  • Type Parameters:
    T - The type of record to write.
    All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.serialization.BulkWriter.Factory<T>
    public class AvroWriterFactory<T>
extends Object
implements org.apache.flink.api.common.serialization.BulkWriter.Factory<T>
    A factory that creates an AvroBulkWriter. The factory takes a user-supplied builder to assemble Parquet's writer and then turns it into a Flink BulkWriter.
    See Also:
    Serialized Form

    • Constructor Detail

      • AvroWriterFactory

        public AvroWriterFactory​(AvroBuilder<T> avroBuilder)
        Creates a new AvroWriterFactory using the given builder to assemble the ParquetWriter.

    • Method Detail

      • create

        public org.apache.flink.api.common.serialization.BulkWriter<T> create​(org.apache.flink.core.fs.FSDataOutputStream out)
                                                               throws IOException
        Specified by:
        create in interface org.apache.flink.api.common.serialization.BulkWriter.Factory<T>
        Throws:
        IOException