InternalReader

java.lang.Object

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

public class InternalReader<T extends StructLike> extends Object

Method Summary

Modifier and Type

Method

Description

protected Object

convertConstant(Type type, Object value)

static <T extends StructLike> ParquetValueReader<T>

create(Schema expectedSchema, org.apache.parquet.schema.MessageType fileSchema)

static <T extends StructLike> ParquetValueReader<T>

create(Schema expectedSchema, org.apache.parquet.schema.MessageType fileSchema, Map<Integer,?> idToConstant)

protected ParquetValueReader<T>

createReader(Schema expectedSchema, org.apache.parquet.schema.MessageType fileSchema)

protected ParquetValueReader<T>

createReader(Schema expectedSchema, org.apache.parquet.schema.MessageType fileSchema, Map<Integer,?> idToConstant)

protected ParquetValueReader<T>

createStructReader(List<ParquetValueReader<?>> fieldReaders, Types.StructType structType)

protected ParquetValueReader<?>

dateReader(org.apache.parquet.column.ColumnDescriptor desc)

protected ParquetValueReader<?>

fixedReader(org.apache.parquet.column.ColumnDescriptor desc)

protected ParquetValueReader<?>

timeReader(org.apache.parquet.column.ColumnDescriptor desc)

protected ParquetValueReader<?>

timestampReader(org.apache.parquet.column.ColumnDescriptor desc, boolean isAdjustedToUTC)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details
- create
  
  public static <T extends StructLike> ParquetValueReader<T> create(Schema expectedSchema, org.apache.parquet.schema.MessageType fileSchema)
- create
  
  public static <T extends StructLike> ParquetValueReader<T> create(Schema expectedSchema, org.apache.parquet.schema.MessageType fileSchema, Map<Integer,?> idToConstant)
- createStructReader
  
  protected ParquetValueReader<T> createStructReader(List<ParquetValueReader<?>> fieldReaders, Types.StructType structType)
- fixedReader
  
  protected ParquetValueReader<?> fixedReader(org.apache.parquet.column.ColumnDescriptor desc)
- dateReader
  
  protected ParquetValueReader<?> dateReader(org.apache.parquet.column.ColumnDescriptor desc)
- timeReader
  
  protected ParquetValueReader<?> timeReader(org.apache.parquet.column.ColumnDescriptor desc)
- timestampReader
  
  protected ParquetValueReader<?> timestampReader(org.apache.parquet.column.ColumnDescriptor desc, boolean isAdjustedToUTC)
- createReader
  
  protected ParquetValueReader<T> createReader(Schema expectedSchema, org.apache.parquet.schema.MessageType fileSchema)
- createReader
  
  protected ParquetValueReader<T> createReader(Schema expectedSchema, org.apache.parquet.schema.MessageType fileSchema, Map<Integer,?> idToConstant)
- convertConstant
  
  protected Object convertConstant(Type type, Object value)