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)
-