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 BulkWriter<T> create(FSDataOutputStream stream) throws IOException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.