T- The type of record to write.
@PublicEvolving public class ParquetWriterFactory<T> extends Object implements BulkWriter.Factory<T>
BulkWriter. 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 ParquetWriterFactory using the given builder to assemble the ParquetWriter.
|Modifier and Type||Method and Description|
Creates a writer that writes to the given stream.
public ParquetWriterFactory(ParquetBuilder<T> writerBuilder)
writerBuilder- The builder to construct the ParquetWriter.
public BulkWriter<T> create(FSDataOutputStream stream) throws IOException
stream- The output stream to write the encoded data to.
IOException- Thrown if the writer cannot be opened, or if the output stream throws an exception.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.