org.apache.paimon.format.parquet.writer

Class ParquetRowDataBuilder

java.lang.Object

org.apache.parquet.hadoop.ParquetWriter.Builder<InternalRow,ParquetRowDataBuilder>

org.apache.paimon.format.parquet.writer.ParquetRowDataBuilder

public class ParquetRowDataBuilder
extends ParquetWriter.Builder<InternalRow,ParquetRowDataBuilder>

InternalRow of ParquetWriter.Builder.

Constructor Summary

Constructors

Constructor and Description
ParquetRowDataBuilder(org.apache.parquet.io.OutputFile path, RowType rowType)

Method Summary

Modifier and Type	Method and Description
protected org.apache.parquet.hadoop.api.WriteSupport<InternalRow>	getWriteSupport(org.apache.hadoop.conf.Configuration conf)
protected ParquetRowDataBuilder	self()

Methods inherited from class org.apache.parquet.hadoop.ParquetWriter.Builder

build, config, enableDictionaryEncoding, enablePageWriteChecksum, enableValidation, withBloomFilterEnabled, withBloomFilterEnabled, withBloomFilterFPP, withBloomFilterNDV, withByteStreamSplitEncoding, withColumnIndexTruncateLength, withCompressionCodec, withConf, withDictionaryEncoding, withDictionaryEncoding, withDictionaryPageSize, withMaxPaddingSize, withMaxRowCountForPageSizeCheck, withMinRowCountForPageSizeCheck, withPageRowCountLimit, withPageSize, withPageWriteChecksumEnabled, withRowGroupSize, withRowGroupSize, withStatisticsTruncateLength, withValidation, withWriteMode, withWriterVersion

Methods inherited from class java.lang.Object

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

Constructor Detail

ParquetRowDataBuilder

public ParquetRowDataBuilder(org.apache.parquet.io.OutputFile path,
                             RowType rowType)

Method Detail

self

protected ParquetRowDataBuilder self()

Specified by:

self in class ParquetWriter.Builder<InternalRow,ParquetRowDataBuilder>

Returns:

this as the correct subclass of ParquetWriter.Builder.

getWriteSupport

protected org.apache.parquet.hadoop.api.WriteSupport<InternalRow> getWriteSupport(org.apache.hadoop.conf.Configuration conf)

Specified by:

getWriteSupport in class ParquetWriter.Builder<InternalRow,ParquetRowDataBuilder>

Parameters:

conf - a configuration

Returns:

an appropriate WriteSupport for the object model.