Package org.apache.iceberg.arrow.vectorized.parquet

Class VectorizedDeltaEncodedValuesReader

java.lang.Object
org.apache.parquet.column.values.ValuesReader
org.apache.iceberg.arrow.vectorized.parquet.VectorizedDeltaEncodedValuesReader
public class VectorizedDeltaEncodedValuesReader extends org.apache.parquet.column.values.ValuesReader
A VectorizedValuesReader implementation for the encoding type DELTA_BINARY_PACKED. This is adapted from Spark's VectorizedDeltaBinaryPackedReader.
See Also:

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final int
    DOUBLE_SIZE
     
    static final int
    FLOAT_SIZE
     
    static final int
    INT_SIZE
     
    static final int
    LONG_SIZE
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    VectorizedDeltaEncodedValuesReader()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    initFromPage(int valueCount, org.apache.parquet.bytes.ByteBufferInputStream in)
     
    default org.apache.parquet.io.api.Binary
    readBinary(int len)
    Read binary data of some length
    default boolean
    readBoolean()
    Read a single boolean
    default byte
    readByte()
    Read a single byte
    default double
    readDouble()
    Read a single double
    default void
    readDoubles(int total, org.apache.arrow.vector.FieldVector vec, int rowId)
    Read `total` doubles into `vec` starting at `vec[rowId]`
    default float
    readFloat()
    Read a single float
    default void
    readFloats(int total, org.apache.arrow.vector.FieldVector vec, int rowId)
    Read `total` floats into `vec` starting at `vec[rowId]`
    int
    readInteger()
     
    void
    readIntegers(int total, org.apache.arrow.vector.FieldVector vec, int rowId)
     
    long
    readLong()
     
    void
    readLongs(int total, org.apache.arrow.vector.FieldVector vec, int rowId)
     
    default short
    readShort()
    Read a single short
    void
    skip()
    The Iceberg reader currently does not do skipping

    Methods inherited from class org.apache.parquet.column.values.ValuesReader

    getNextOffset, initFromPage, initFromPage, readBoolean, readBytes, readDouble, readFloat, readValueDictionaryId, skip, updateNextOffset

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

  • Constructor Details

    • VectorizedDeltaEncodedValuesReader

      public VectorizedDeltaEncodedValuesReader()

  • Method Details

    • initFromPage

      public void initFromPage(int valueCount, org.apache.parquet.bytes.ByteBufferInputStream in) throws IOException
      Overrides:
      initFromPage in class org.apache.parquet.column.values.ValuesReader
      Throws:
      IOException

    • readInteger

      public int readInteger()
      Overrides:
      readInteger in class org.apache.parquet.column.values.ValuesReader

    • readLong

      public long readLong()
      Overrides:
      readLong in class org.apache.parquet.column.values.ValuesReader

    • skip

      public void skip()
      The Iceberg reader currently does not do skipping
      Specified by:
      skip in class org.apache.parquet.column.values.ValuesReader

    • readIntegers

      public void readIntegers(int total, org.apache.arrow.vector.FieldVector vec, int rowId)

    • readLongs

      public void readLongs(int total, org.apache.arrow.vector.FieldVector vec, int rowId)

    • readBoolean

      default boolean readBoolean()
      Read a single boolean

    • readByte

      default byte readByte()
      Read a single byte

    • readShort

      default short readShort()
      Read a single short

    • readFloat

      default float readFloat()
      Read a single float

    • readDouble

      default double readDouble()
      Read a single double

    • readBinary

      default org.apache.parquet.io.api.Binary readBinary(int len)
      Read binary data of some length
      Parameters:
      len - The number of bytes to read

    • readFloats

      default void readFloats(int total, org.apache.arrow.vector.FieldVector vec, int rowId)
      Read `total` floats into `vec` starting at `vec[rowId]`

    • readDoubles

      default void readDoubles(int total, org.apache.arrow.vector.FieldVector vec, int rowId)
      Read `total` doubles into `vec` starting at `vec[rowId]`