Package org.apache.iceberg.data.parquet

Class InternalReader<T extends StructLike>

java.lang.Object

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

public class InternalReader<T extends StructLike>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected static final int	ROOT_ID

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)	Deprecated. will be removed in 1.12.0.
protected ParquetValueReader<T>	createStructReader(List<ParquetValueReader<?>> fieldReaders, Types.StructType structType, Integer fieldId)	This method can be overridden to provide a custom implementation which also uses the fieldId of the Schema when creating the struct reader
protected ParquetValueReader<?>	dateReader(org.apache.parquet.column.ColumnDescriptor desc)
protected ParquetValueReader<?>	fixedReader(org.apache.parquet.column.ColumnDescriptor desc)
static Parquet.ReadBuilder.ReaderFunction	readerFunction()
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

Field Details

ROOT_ID

protected static final int ROOT_ID

See Also:

• Constant Field Values

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)

readerFunction

public static Parquet.ReadBuilder.ReaderFunction readerFunction()

createStructReader

protected ParquetValueReader<T> createStructReader(List<ParquetValueReader<?>> fieldReaders,
 Types.StructType structType,
 Integer fieldId)

This method can be overridden to provide a custom implementation which also uses the fieldId of the Schema when creating the struct reader

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)

createStructReader

@Deprecated
protected ParquetValueReader<T> createStructReader(List<ParquetValueReader<?>> fieldReaders,
 Types.StructType structType)

Deprecated.

will be removed in 1.12.0. Subclasses should override createStructReader(List, Types.StructType, Integer) instead

convertConstant

protected Object convertConstant(Type type,
 Object value)