Package org.apache.flink.formats.parquet.row

Class ParquetRowDataBuilder.FlinkParquetBuilder

java.lang.Object

org.apache.flink.formats.parquet.row.ParquetRowDataBuilder.FlinkParquetBuilder

All Implemented Interfaces:

Serializable, ParquetBuilder<RowData>

Enclosing class:

ParquetRowDataBuilder

public static class ParquetRowDataBuilder.FlinkParquetBuilder
extends Object
implements ParquetBuilder<RowData>

Flink Row ParquetBuilder.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
FlinkParquetBuilder(RowType rowType, org.apache.hadoop.conf.Configuration conf, boolean utcTimestamp)

Method Summary

Modifier and Type	Method	Description
org.apache.parquet.hadoop.ParquetWriter<RowData>	createWriter(org.apache.parquet.io.OutputFile out)	Creates and configures a parquet writer to the given output file.

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkParquetBuilder

public FlinkParquetBuilder(RowType rowType,
                           org.apache.hadoop.conf.Configuration conf,
                           boolean utcTimestamp)

Method Detail

createWriter

public org.apache.parquet.hadoop.ParquetWriter<RowData> createWriter(org.apache.parquet.io.OutputFile out)
                                                              throws IOException

Description copied from interface: ParquetBuilder

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

Specified by:

createWriter in interface ParquetBuilder<RowData>

Throws:

IOException