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 java.lang.Object implements ParquetValueReader<T>
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
RepeatedReader(int definitionLevel, int repetitionLevel, ParquetValueReader<E> reader)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods 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()
java.util.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, long rowPosition)
-
-
-
Constructor Detail
-
RepeatedReader
protected RepeatedReader(int definitionLevel, int repetitionLevel, ParquetValueReader<E> reader)
-
-
Method Detail
-
setPageSource
public void setPageSource(org.apache.parquet.column.page.PageReadStore pageStore, long rowPosition)
- Specified by:
setPageSource
in interfaceParquetValueReader<T>
-
column
public org.apache.iceberg.parquet.TripleIterator<?> column()
- Specified by:
column
in interfaceParquetValueReader<T>
-
read
public T read(T reuse)
- Specified by:
read
in interfaceParquetValueReader<T>
-
columns
public java.util.List<org.apache.iceberg.parquet.TripleIterator<?>> columns()
- Specified by:
columns
in interfaceParquetValueReader<T>
-
-