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 Details

    • RepeatedReader

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

  • 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>

    • 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)