Package org.apache.iceberg.parquet

Class ParquetValueReaders.StructReader<T,I>

java.lang.Object
org.apache.iceberg.parquet.ParquetValueReaders.StructReader<T,I>
All Implemented Interfaces:
ParquetValueReader<T>
Enclosing class:
ParquetValueReaders
public abstract static class ParquetValueReaders.StructReader<T,I> extends Object implements ParquetValueReader<T>

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    StructReader(List<org.apache.parquet.schema.Type> types, List<ParquetValueReader<?>> readers)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected abstract T
    buildStruct(I struct)
     
    final org.apache.iceberg.parquet.TripleIterator<?>
    column()
     
    List<org.apache.iceberg.parquet.TripleIterator<?>>
    columns()
     
    protected abstract Object
    getField(I intermediate, int pos)
     
    protected abstract I
    newStructData(T reuse)
     
    final T
    read(T reuse)
     
    protected abstract void
    set(I struct, int pos, Object value)
    Used to set a struct value by position.
    protected void
    setBoolean(I struct, int pos, boolean value)
     
    protected void
    setDouble(I struct, int pos, double value)
     
    protected void
    setFloat(I struct, int pos, float value)
     
    protected void
    setInteger(I struct, int pos, int value)
     
    protected void
    setLong(I struct, int pos, long value)
     
    protected void
    setNull(I struct, int pos)
     
    final 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

  • Constructor Details

  • Method Details

    • setPageSource

      public final void setPageSource(org.apache.parquet.column.page.PageReadStore pageStore, long rowPosition)
      Specified by:
      setPageSource in interface ParquetValueReader<T>

    • column

      public final org.apache.iceberg.parquet.TripleIterator<?> column()
      Specified by:
      column in interface ParquetValueReader<T>

    • read

      public final 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>

    • newStructData

      protected abstract I newStructData(T reuse)

    • getField

      protected abstract Object getField(I intermediate, int pos)

    • buildStruct

      protected abstract T buildStruct(I struct)

    • set

      protected abstract void set(I struct, int pos, Object value)
      Used to set a struct value by position.

      To avoid boxing, override setInteger(Object, int, int) and similar methods.

      Parameters:
      struct - a struct object created by newStructData(Object)
      pos - the position in the struct to set
      value - the value to set

    • setNull

      protected void setNull(I struct, int pos)

    • setBoolean

      protected void setBoolean(I struct, int pos, boolean value)

    • setInteger

      protected void setInteger(I struct, int pos, int value)

    • setLong

      protected void setLong(I struct, int pos, long value)

    • setFloat

      protected void setFloat(I struct, int pos, float value)

    • setDouble

      protected void setDouble(I struct, int pos, double value)