Package org.apache.iceberg.parquet

Class ParquetValueReaders

java.lang.Object

org.apache.iceberg.parquet.ParquetValueReaders

public class ParquetValueReaders
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ParquetValueReaders.BinaryAsDecimalReader
static class	ParquetValueReaders.ByteArrayReader
static class	ParquetValueReaders.BytesReader
static class	ParquetValueReaders.FloatAsDoubleReader
static class	ParquetValueReaders.IntAsLongReader
static class	ParquetValueReaders.IntegerAsDecimalReader
static class	ParquetValueReaders.ListReader<E>
static class	ParquetValueReaders.LongAsDecimalReader
static class	ParquetValueReaders.MapReader<K,V>
static class	ParquetValueReaders.PrimitiveReader<T>
static class	ParquetValueReaders.RepeatedKeyValueReader<M,I,K,V>
static class	ParquetValueReaders.RepeatedReader<T,I,E>
static class	ParquetValueReaders.ReusableEntry<K,V>
static class	ParquetValueReaders.StringReader
static class	ParquetValueReaders.StructReader<T,I>
static class	ParquetValueReaders.UnboxedReader<T>

Method Summary

Modifier and Type	Method	Description
static 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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

option

public static <T> ParquetValueReader<T> option(org.apache.parquet.schema.Type type,
 int definitionLevel,
 ParquetValueReader<T> reader)

unboxed

public static ParquetValueReader<Integer> unboxed(org.apache.parquet.column.ColumnDescriptor desc)

intsAsByte

public static ParquetValueReader<Byte> intsAsByte(org.apache.parquet.column.ColumnDescriptor desc)

intsAsShort

public static ParquetValueReader<Short> intsAsShort(org.apache.parquet.column.ColumnDescriptor desc)

strings

public static ParquetValueReader<String> strings(org.apache.parquet.column.ColumnDescriptor desc)

byteBuffers

public static ParquetValueReader<ByteBuffer> byteBuffers(org.apache.parquet.column.ColumnDescriptor desc)

intsAsLongs

public static ParquetValueReader<Long> intsAsLongs(org.apache.parquet.column.ColumnDescriptor desc)

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

public static ParquetValueReader<Long> times(org.apache.parquet.column.ColumnDescriptor desc)

timestamps

public static ParquetValueReader<Long> timestamps(org.apache.parquet.column.ColumnDescriptor desc)

nulls

public static <T> ParquetValueReader<T> nulls()

constant

public static <C> ParquetValueReader<C> constant(C value)

constant

public static <C> ParquetValueReader<C> constant(C value,
 int definitionLevel)

position

public static ParquetValueReader<Long> position()

rowIds

public static ParquetValueReader<Long> rowIds(Long baseRowId,
 ParquetValueReader<?> idReader)

lastUpdated

public static ParquetValueReader<Long> lastUpdated(Long baseRowId,
 Long fileLastUpdated,
 ParquetValueReader<?> seqReader)

uuids

public static ParquetValueReader<UUID> uuids(org.apache.parquet.column.ColumnDescriptor desc)

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)