public class AvroBulkWriter<T> extends Object implements Closeable
DataFileWriter
.Constructor and Description |
---|
AvroBulkWriter(org.apache.avro.file.DataFileWriter<T> dataFileWriter)
Create a new AvroBulkWriter wrapping the given Avro
DataFileWriter . |
public AvroBulkWriter(org.apache.avro.file.DataFileWriter<T> dataFileWriter)
DataFileWriter
.dataFileWriter
- The underlying Avro writer.public void addElement(T element) throws IOException
IOException
public void flush() throws IOException
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.