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

Class ParquetRowDataWriter

java.lang.Object

org.apache.flink.formats.parquet.row.ParquetRowDataWriter

public class ParquetRowDataWriter
extends Object

Writes a record to the Parquet API with the expected schema in order to be written to a file.

Constructor Summary

Constructors

Constructor	Description
ParquetRowDataWriter(org.apache.parquet.io.api.RecordConsumer recordConsumer, org.apache.flink.table.types.logical.RowType rowType, org.apache.parquet.schema.GroupType schema, boolean utcTimestamp, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
void	write(org.apache.flink.table.data.RowData record)	It writes a record to Parquet.

Methods inherited from class java.lang.Object

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

Constructor Detail

ParquetRowDataWriter

public ParquetRowDataWriter(org.apache.parquet.io.api.RecordConsumer recordConsumer,
                            org.apache.flink.table.types.logical.RowType rowType,
                            org.apache.parquet.schema.GroupType schema,
                            boolean utcTimestamp,
                            org.apache.hadoop.conf.Configuration conf)

Method Detail

write

public void write(org.apache.flink.table.data.RowData record)

It writes a record to Parquet.

Parameters:

record - Contains the record that is going to be written.