Interface ParquetValueReader<T>

All Known Implementing Classes:
ParquetAvroValueReaders.TimeMillisReader, ParquetAvroValueReaders.TimestampMillisReader, ParquetValueReaders.BinaryAsDecimalReader, ParquetValueReaders.ByteArrayReader, ParquetValueReaders.BytesReader, ParquetValueReaders.FloatAsDoubleReader, ParquetValueReaders.IntAsLongReader, ParquetValueReaders.IntegerAsDecimalReader, ParquetValueReaders.ListReader, ParquetValueReaders.LongAsDecimalReader, ParquetValueReaders.MapReader, ParquetValueReaders.PrimitiveReader, ParquetValueReaders.RepeatedKeyValueReader, ParquetValueReaders.RepeatedReader, ParquetValueReaders.StringReader, ParquetValueReaders.StructReader, ParquetValueReaders.UnboxedReader

public interface ParquetValueReader<T>
  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.iceberg.parquet.TripleIterator<?>
     
    List<org.apache.iceberg.parquet.TripleIterator<?>>
     
    read(T reuse)
     
    void
    setPageSource(org.apache.parquet.column.page.PageReadStore pageStore, long rowPosition)
     
  • Method Details

    • read

      T read(T reuse)
    • column

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

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

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