T- The type of record to write.
public class AvroWriterFactory<T> extends Object implements BulkWriter.Factory<T>
AvroBulkWriter. The factory takes a user-supplied builder to assemble Parquet's writer and then turns it into a Flink
|Constructor and Description|
Creates a new AvroWriterFactory using the given builder to assemble the ParquetWriter.
|Modifier and Type||Method and Description|
Creates a writer that writes to the given stream.
public BulkWriter<T> create(FSDataOutputStream out) throws IOException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.