InternalWriter

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)

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