Package org.apache.iceberg.data.parquet

Class InternalWriter<T extends StructLike>

java.lang.Object

org.apache.iceberg.data.parquet.InternalWriter<T>

public class InternalWriter<T extends StructLike>
extends Object

A Writer that consumes Iceberg's internal in-memory object model.

Iceberg's internal in-memory object model produces the types defined in Type.TypeID.javaClass().

Method Summary

Modifier and Type	Method	Description
static <T extends StructLike> ParquetValueWriter<T>	create(Types.StructType struct, org.apache.parquet.schema.MessageType type)
static <T extends StructLike> ParquetValueWriter<T>	create(org.apache.parquet.schema.MessageType type)	Deprecated. will be removed in 1.10.0; use createWriter(Schema, MessageType) instead.
protected ParquetValueWriters.StructWriter<T>	createStructWriter(List<ParquetValueWriter<?>> writers)	Deprecated. will be removed in 1.10.0; use createWriter(Types.StructType, MessageType) instead.
protected ParquetValueWriters.StructWriter<T>	createStructWriter(Types.StructType struct, List<ParquetValueWriter<?>> writers)
static <T extends StructLike> ParquetValueWriter<T>	createWriter(Schema schema, org.apache.parquet.schema.MessageType type)
protected ParquetValueWriter<T>	createWriter(Types.StructType struct, org.apache.parquet.schema.MessageType type)
protected ParquetValueWriter<T>	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)

Methods inherited from class java.lang.Object

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

Method Details

create

@Deprecated
public static <T extends StructLike>
ParquetValueWriter<T> create(org.apache.parquet.schema.MessageType type)

Deprecated.

will be removed in 1.10.0; use createWriter(Schema, MessageType) instead.

Build a writer for a Parquet schema.

createWriter

public static <T extends StructLike>
ParquetValueWriter<T> createWriter(Schema schema,
 org.apache.parquet.schema.MessageType type)

create

public static <T extends StructLike>
ParquetValueWriter<T> create(Types.StructType struct,
 org.apache.parquet.schema.MessageType type)

createStructWriter

@Deprecated
protected ParquetValueWriters.StructWriter<T> createStructWriter(List<ParquetValueWriter<?>> writers)

Deprecated.

will be removed in 1.10.0; use createWriter(Types.StructType, MessageType) instead.

Create a struct writer from a list of writers.

createStructWriter

protected ParquetValueWriters.StructWriter<T> createStructWriter(Types.StructType struct,
 List<ParquetValueWriter<?>> writers)

fixedWriter

protected ParquetValueWriter<?> fixedWriter(org.apache.parquet.column.ColumnDescriptor desc)

dateWriter

protected ParquetValueWriter<?> dateWriter(org.apache.parquet.column.ColumnDescriptor desc)

timeWriter

protected ParquetValueWriter<?> timeWriter(org.apache.parquet.column.ColumnDescriptor desc)

timestampWriter

protected ParquetValueWriter<?> timestampWriter(org.apache.parquet.column.ColumnDescriptor desc,
 boolean isAdjustedToUTC)

createWriter

protected ParquetValueWriter<T> createWriter(org.apache.parquet.schema.MessageType type)

createWriter

protected ParquetValueWriter<T> createWriter(Types.StructType struct,
 org.apache.parquet.schema.MessageType type)