org.apache.iceberg.parquet

Class ParquetValueReaders.PrimitiveReader<T>

java.lang.Object

org.apache.iceberg.parquet.ParquetValueReaders.PrimitiveReader<T>

All Implemented Interfaces:

ParquetValueReader<T>

Direct Known Subclasses:

ParquetValueReaders.BinaryAsDecimalReader, ParquetValueReaders.ByteArrayReader, ParquetValueReaders.BytesReader, ParquetValueReaders.IntegerAsDecimalReader, ParquetValueReaders.LongAsDecimalReader, ParquetValueReaders.StringReader, ParquetValueReaders.UnboxedReader

Enclosing class:

ParquetValueReaders

public abstract static class ParquetValueReaders.PrimitiveReader<T>
extends java.lang.Object
implements ParquetValueReader<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected ColumnIterator<?>	column

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PrimitiveReader(org.apache.parquet.column.ColumnDescriptor desc)

Method Summary

Modifier and Type	Method and Description
org.apache.iceberg.parquet.TripleIterator<?>	column()
java.util.List<org.apache.iceberg.parquet.TripleIterator<?>>	columns()
void	setPageSource(org.apache.parquet.column.page.PageReadStore pageStore, long rowPosition)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iceberg.parquet.ParquetValueReader

read

Field Detail

column

protected final ColumnIterator<?> column

Constructor Detail

PrimitiveReader

protected PrimitiveReader(org.apache.parquet.column.ColumnDescriptor desc)

Method Detail

setPageSource

public void setPageSource(org.apache.parquet.column.page.PageReadStore pageStore,
                          long rowPosition)

Specified by:

setPageSource in interface ParquetValueReader<T>

column

public org.apache.iceberg.parquet.TripleIterator<?> column()

Specified by:

column in interface ParquetValueReader<T>

columns

public java.util.List<org.apache.iceberg.parquet.TripleIterator<?>> columns()

Specified by:

columns in interface ParquetValueReader<T>