public static class ParquetRowDataBuilder.FlinkParquetBuilder extends Object implements ParquetBuilder<RowData>
ParquetBuilder
.Constructor and Description |
---|
FlinkParquetBuilder(RowType rowType,
Configuration conf,
boolean utcTimestamp) |
Modifier and Type | Method and 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.
|
public FlinkParquetBuilder(RowType rowType, Configuration conf, boolean utcTimestamp)
public org.apache.parquet.hadoop.ParquetWriter<RowData> createWriter(org.apache.parquet.io.OutputFile out) throws IOException
ParquetBuilder
createWriter
in interface ParquetBuilder<RowData>
IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.