Package org.apache.iceberg.parquet
Class ParquetValueReaders
java.lang.Object
org.apache.iceberg.parquet.ParquetValueReaders
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
-
Method Summary
Modifier and TypeMethodDescriptionstatic ParquetValueReader<BigDecimal>
bigDecimals
(org.apache.parquet.column.ColumnDescriptor desc) static ParquetValueReader<ByteBuffer>
byteBuffers
(org.apache.parquet.column.ColumnDescriptor desc) static <C> ParquetValueReader<C>
constant
(C value) static <C> ParquetValueReader<C>
constant
(C value, int definitionLevel) static ParquetValueReader<Double>
floatsAsDoubles
(org.apache.parquet.column.ColumnDescriptor desc) static ParquetValueReader<Long>
int96Timestamps
(org.apache.parquet.column.ColumnDescriptor desc) static ParquetValueReader<Byte>
intsAsByte
(org.apache.parquet.column.ColumnDescriptor desc) static ParquetValueReader<Long>
intsAsLongs
(org.apache.parquet.column.ColumnDescriptor desc) static ParquetValueReader<Short>
intsAsShort
(org.apache.parquet.column.ColumnDescriptor desc) static ParquetValueReader<Long>
lastUpdated
(Long baseRowId, Long fileLastUpdated, ParquetValueReader<?> seqReader) static <T> ParquetValueReader<T>
nulls()
static <T> ParquetValueReader<T>
option
(org.apache.parquet.schema.Type type, int definitionLevel, ParquetValueReader<T> reader) static ParquetValueReader<Long>
position()
static ParquetValueReader<Record>
recordReader
(List<ParquetValueReader<?>> readers, Types.StructType struct) static ParquetValueReader<?>
replaceWithMetadataReader
(int id, ParquetValueReader<?> reader, Map<Integer, ?> idToConstant, int constantDL) static ParquetValueReader<Long>
rowIds
(Long baseRowId, ParquetValueReader<?> idReader) static ParquetValueReader<String>
strings
(org.apache.parquet.column.ColumnDescriptor desc) static ParquetValueReader<Long>
times
(org.apache.parquet.column.ColumnDescriptor desc) static ParquetValueReader<Long>
timestamps
(org.apache.parquet.column.ColumnDescriptor desc) static ParquetValueReader<Integer>
unboxed
(org.apache.parquet.column.ColumnDescriptor desc) static ParquetValueReader<UUID>
uuids
(org.apache.parquet.column.ColumnDescriptor desc)
-
Method Details
-
option
public static <T> ParquetValueReader<T> option(org.apache.parquet.schema.Type type, int definitionLevel, ParquetValueReader<T> reader) -
unboxed
-
intsAsByte
-
intsAsShort
public static ParquetValueReader<Short> intsAsShort(org.apache.parquet.column.ColumnDescriptor desc) -
strings
-
byteBuffers
public static ParquetValueReader<ByteBuffer> byteBuffers(org.apache.parquet.column.ColumnDescriptor desc) -
intsAsLongs
-
floatsAsDoubles
public static ParquetValueReader<Double> floatsAsDoubles(org.apache.parquet.column.ColumnDescriptor desc) -
bigDecimals
public static ParquetValueReader<BigDecimal> bigDecimals(org.apache.parquet.column.ColumnDescriptor desc) -
times
-
timestamps
-
nulls
-
constant
-
constant
-
position
-
rowIds
-
lastUpdated
public static ParquetValueReader<Long> lastUpdated(Long baseRowId, Long fileLastUpdated, ParquetValueReader<?> seqReader) -
uuids
-
int96Timestamps
public static ParquetValueReader<Long> int96Timestamps(org.apache.parquet.column.ColumnDescriptor desc) -
recordReader
public static ParquetValueReader<Record> recordReader(List<ParquetValueReader<?>> readers, Types.StructType struct) -
replaceWithMetadataReader
public static ParquetValueReader<?> replaceWithMetadataReader(int id, ParquetValueReader<?> reader, Map<Integer, ?> idToConstant, int constantDL)
-