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

Class VectorizedByteStreamSplitValuesReader

java.lang.Object
org.apache.parquet.column.values.ValuesReader
org.apache.iceberg.arrow.vectorized.parquet.VectorizedByteStreamSplitValuesReader
public class VectorizedByteStreamSplitValuesReader extends org.apache.parquet.column.values.ValuesReader
A VectorizedValuesReader implementation for the encoding type BYTE_STREAM_SPLIT. This is adapted from Parquet's ByteStreamSplitValuesReader.
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
    VectorizedByteStreamSplitValuesReader(int elementSizeInBytes)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    initFromPage(int ignoredValueCount, org.apache.parquet.bytes.ByteBufferInputStream in)
     
    org.apache.parquet.io.api.Binary
    readBinary(int len)
     
    default boolean
    readBoolean()
    Read a single boolean
    default byte
    readByte()
    Read a single byte
    double
    readDouble()
     
    void
    readDoubles(int total, org.apache.arrow.vector.FieldVector vec, int rowId)
     
    float
    readFloat()
     
    void
    readFloats(int total, org.apache.arrow.vector.FieldVector vec, int 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()
     

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

    getNextOffset, initFromPage, initFromPage, readBoolean, readBytes, 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

    • VectorizedByteStreamSplitValuesReader

      public VectorizedByteStreamSplitValuesReader(int elementSizeInBytes)

  • Method Details

    • initFromPage

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

    • 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

    • readFloat

      public float readFloat()
      Overrides:
      readFloat in class org.apache.parquet.column.values.ValuesReader

    • readDouble

      public double readDouble()
      Overrides:
      readDouble in class org.apache.parquet.column.values.ValuesReader

    • readBinary

      public org.apache.parquet.io.api.Binary readBinary(int len)

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

    • readFloats

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

    • readDoubles

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

    • skip

      public void skip()
      Specified by:
      skip in class org.apache.parquet.column.values.ValuesReader

    • readBoolean

      default boolean readBoolean()
      Read a single boolean

    • readByte

      default byte readByte()
      Read a single byte

    • readShort

      default short readShort()
      Read a single short