Package 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 Object
implements ParquetValueReader<T>

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
org.apache.iceberg.parquet.TripleIterator<?>	column()
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 Details

column

protected final ColumnIterator<?> column

Constructor Details

PrimitiveReader

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

Method Details

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 List<org.apache.iceberg.parquet.TripleIterator<?>> columns()

Specified by:

columns in interface ParquetValueReader<T>