GenericParquetReaders

java.lang.Object

org.apache.iceberg.data.parquet.GenericParquetReaders

public class GenericParquetReaders extends Object

Method Summary

Modifier and Type

Method

Description

static ParquetValueReader<Record>

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

static ParquetValueReader<Record>

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

protected Object

convertConstant(Type type, Object value)

protected ParquetValueReader<Record>

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

protected ParquetValueReader<Record>

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

protected ParquetValueReader<Record>

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
- buildReader
  
  public static ParquetValueReader<Record> buildReader(Schema expectedSchema, org.apache.parquet.schema.MessageType fileSchema)
- buildReader
  
  public static ParquetValueReader<Record> buildReader(Schema expectedSchema, org.apache.parquet.schema.MessageType fileSchema, Map<Integer,?> idToConstant)
- createStructReader
  
  protected ParquetValueReader<Record> 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)
- convertConstant
  
  protected Object convertConstant(Type type, Object value)
- createReader
  
  protected ParquetValueReader<Record> createReader(Schema expectedSchema, org.apache.parquet.schema.MessageType fileSchema)
- createReader
  
  protected ParquetValueReader<Record> createReader(Schema expectedSchema, org.apache.parquet.schema.MessageType fileSchema, Map<Integer,?> idToConstant)