org.apache.paimon.format.parquet.writer

Class RowDataParquetBuilder

java.lang.Object

org.apache.paimon.format.parquet.writer.RowDataParquetBuilder

All Implemented Interfaces:

Serializable, ParquetBuilder<InternalRow>

public class RowDataParquetBuilder
extends Object
implements ParquetBuilder<InternalRow>

A ParquetBuilder for InternalRow.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RowDataParquetBuilder(RowType rowType, Options options)

Method Summary

Modifier and Type	Method and Description
ParquetWriter<InternalRow>	createWriter(org.apache.parquet.io.OutputFile out, String compression) Creates and configures a parquet writer to the given output file.
String	getCompression(String compression)

Methods inherited from class java.lang.Object

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

Constructor Detail

RowDataParquetBuilder

public RowDataParquetBuilder(RowType rowType,
                             Options options)

Method Detail

createWriter

public ParquetWriter<InternalRow> createWriter(org.apache.parquet.io.OutputFile out,
                                               String compression)
                                        throws IOException

Description copied from interface: ParquetBuilder

Creates and configures a parquet writer to the given output file.

Specified by:

createWriter in interface ParquetBuilder<InternalRow>

Throws:

IOException

getCompression

public String getCompression(String compression)