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 BulkWriter
.Constructor and Description |
---|
AvroWriterFactory(AvroBuilder<T> avroBuilder)
Creates a new AvroWriterFactory using the given builder to assemble the ParquetWriter.
|
Modifier and Type | Method and Description |
---|---|
BulkWriter<T> |
create(FSDataOutputStream out)
Creates a writer that writes to the given stream.
|
public AvroWriterFactory(AvroBuilder<T> avroBuilder)
public BulkWriter<T> create(FSDataOutputStream out) throws IOException
BulkWriter.Factory
create
in interface BulkWriter.Factory<T>
out
- 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–2024 The Apache Software Foundation. All rights reserved.