Package org.apache.iceberg.data.parquet
Class GenericParquetWriter
java.lang.Object
org.apache.iceberg.data.parquet.GenericParquetWriter
-
Method Summary
Modifier and TypeMethodDescriptionstatic ParquetValueWriter<Record> protected ParquetValueWriters.StructWriter<Record> createStructWriter(Types.StructType struct, List<ParquetValueWriter<?>> writers) protected ParquetValueWriter<Record> createWriter(Types.StructType struct, org.apache.parquet.schema.MessageType type) protected ParquetValueWriter<Record> createWriter(org.apache.parquet.schema.MessageType type) protected ParquetValueWriter<?> dateWriter(org.apache.parquet.column.ColumnDescriptor desc) protected ParquetValueWriter<?> fixedWriter(org.apache.parquet.column.ColumnDescriptor desc) protected ParquetValueWriter<?> timestampWriter(org.apache.parquet.column.ColumnDescriptor desc, boolean isAdjustedToUTC) protected ParquetValueWriter<?> timeWriter(org.apache.parquet.column.ColumnDescriptor desc)
-
Method Details
-
create
public static ParquetValueWriter<Record> create(Schema schema, org.apache.parquet.schema.MessageType type) -
createStructWriter
protected ParquetValueWriters.StructWriter<Record> createStructWriter(Types.StructType struct, List<ParquetValueWriter<?>> writers) -
fixedWriter
-
dateWriter
-
timeWriter
-
timestampWriter
protected ParquetValueWriter<?> timestampWriter(org.apache.parquet.column.ColumnDescriptor desc, boolean isAdjustedToUTC) -
createWriter
-
createWriter
protected ParquetValueWriter<Record> createWriter(Types.StructType struct, org.apache.parquet.schema.MessageType type)
-