Package org.apache.iceberg.data.parquet
Class GenericParquetReaders
java.lang.Object
org.apache.iceberg.data.parquet.GenericParquetReaders
-
Method Summary
Modifier and TypeMethodDescriptionstatic 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<Record>
createStructReader
(List<org.apache.parquet.schema.Type> types, List<ParquetValueReader<?>> fieldReaders, Types.StructType structType) Deprecated.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)
-
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
@Deprecated protected ParquetValueReader<Record> createStructReader(List<org.apache.parquet.schema.Type> types, List<ParquetValueReader<?>> fieldReaders, Types.StructType structType) Deprecated.will be removed in 1.10.0; usecreateStructReader(List, StructType)
instead.Create a struct reader. -
createStructReader
protected ParquetValueReader<Record> createStructReader(List<ParquetValueReader<?>> fieldReaders, Types.StructType structType) -
fixedReader
-
dateReader
-
timeReader
-
timestampReader
protected ParquetValueReader<?> timestampReader(org.apache.parquet.column.ColumnDescriptor desc, boolean isAdjustedToUTC) -
convertConstant
-
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)
-
createStructReader(List, StructType)
instead.