InternalReader

java.lang.Object

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

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

public class InternalReader<T extends StructLike> extends BaseParquetReaders<T>

Method Summary

Modifier and Type

Method

Description

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>

createStructReader(List<org.apache.parquet.schema.Type> types, 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 org.apache.iceberg.data.parquet.BaseParquetReaders
convertConstant, createReader, createReader

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<org.apache.parquet.schema.Type> types, List<ParquetValueReader<?>> fieldReaders, Types.StructType structType)
  
  Specified by:
  
  createStructReader in class BaseParquetReaders<T extends StructLike>
- fixedReader
  
  protected ParquetValueReader<?> fixedReader(org.apache.parquet.column.ColumnDescriptor desc)
  
  Overrides:
  
  fixedReader in class BaseParquetReaders<T extends StructLike>
- dateReader
  
  protected ParquetValueReader<?> dateReader(org.apache.parquet.column.ColumnDescriptor desc)
  
  Overrides:
  
  dateReader in class BaseParquetReaders<T extends StructLike>
- timeReader
  
  protected ParquetValueReader<?> timeReader(org.apache.parquet.column.ColumnDescriptor desc)
  
  Overrides:
  
  timeReader in class BaseParquetReaders<T extends StructLike>
- timestampReader
  
  protected ParquetValueReader<?> timestampReader(org.apache.parquet.column.ColumnDescriptor desc, boolean isAdjustedToUTC)
  
  Overrides:
  
  timestampReader in class BaseParquetReaders<T extends StructLike>