org.apache.flink.formats.parquet

Class ParquetBulkWriter<T>

java.lang.Object

org.apache.flink.formats.parquet.ParquetBulkWriter<T>

Type Parameters:

T - The type of records written.

All Implemented Interfaces:

BulkWriter<T>

@PublicEvolving
public class ParquetBulkWriter<T>
extends Object
implements BulkWriter<T>

A simple BulkWriter implementation that wraps a ParquetWriter.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.api.common.serialization.BulkWriter

BulkWriter.Factory<T>

Constructor Summary

Constructors

Constructor and Description
ParquetBulkWriter(org.apache.parquet.hadoop.ParquetWriter<T> parquetWriter) Creates a new ParquetBulkWriter wrapping the given ParquetWriter.

Method Summary

Modifier and Type	Method and Description
void	addElement(T datum) Adds an element to the encoder.
void	finish() Finishes the writing.
void	flush() Flushes all intermediate buffered data to the output stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ParquetBulkWriter

public ParquetBulkWriter(org.apache.parquet.hadoop.ParquetWriter<T> parquetWriter)

Creates a new ParquetBulkWriter wrapping the given ParquetWriter.

Parameters:

parquetWriter - The ParquetWriter to write to.

Method Detail

addElement

public void addElement(T datum)
                throws IOException

Description copied from interface: BulkWriter

Adds an element to the encoder. The encoder may temporarily buffer the element, or immediately write it to the stream.

It may be that adding this element fills up an internal buffer and causes the encoding and flushing of a batch of internally buffered elements.

Specified by:

addElement in interface BulkWriter<T>

Parameters:

datum - The element to add.

Throws:

IOException - Thrown, if the element cannot be added to the encoder, or if the output stream throws an exception.

flush

public void flush()

Description copied from interface: BulkWriter

Flushes all intermediate buffered data to the output stream. It is expected that flushing often may reduce the efficiency of the encoding.

Specified by:

flush in interface BulkWriter<T>

finish

public void finish()
            throws IOException

Description copied from interface: BulkWriter

Finishes the writing. This must flush all internal buffer, finish encoding, and write footers.

The writer is not expected to handle any more records via BulkWriter.addElement(Object) after this method is called.

Important: This method MUST NOT close the stream that the writer writes to. Closing the stream is expected to happen through the invoker of this method afterwards.

Specified by:

finish in interface BulkWriter<T>

Throws:

IOException - Thrown if the finalization fails.