Package org.apache.iceberg.parquet

Class ParquetValueReaders.RepeatedReader<T,I,E>

java.lang.Object

org.apache.iceberg.parquet.ParquetValueReaders.RepeatedReader<T,I,E>

All Implemented Interfaces:

ParquetValueReader<T>

Direct Known Subclasses:

ParquetValueReaders.ListReader

Enclosing class:

ParquetValueReaders

public abstract static class ParquetValueReaders.RepeatedReader<T,I,E>
extends Object
implements ParquetValueReader<T>

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RepeatedReader(int definitionLevel, int repetitionLevel, ParquetValueReader<E> reader)

Method Summary

Modifier and Type	Method	Description
protected abstract void	addElement(I list, E element)
protected abstract T	buildList(I list)
org.apache.iceberg.parquet.TripleIterator<?>	column()
List<org.apache.iceberg.parquet.TripleIterator<?>>	columns()
protected abstract E	getElement(I list)
protected abstract I	newListData(T reuse)
T	read(T reuse)
void	setPageSource(org.apache.parquet.column.page.PageReadStore pageStore)

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

setPageSource

Constructor Details

RepeatedReader

protected RepeatedReader(int definitionLevel,
 int repetitionLevel,
 ParquetValueReader<E> reader)

Method Details

setPageSource

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

Specified by:

setPageSource in interface ParquetValueReader<T>

column

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

Specified by:

column in interface ParquetValueReader<T>

read

public T read(T reuse)

Specified by:

read in interface ParquetValueReader<T>

columns

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

Specified by:

columns in interface ParquetValueReader<T>

newListData

protected abstract I newListData(T reuse)

getElement

protected abstract E getElement(I list)

addElement

protected abstract void addElement(I list,
 E element)

buildList

protected abstract T buildList(I list)