Class DecimalColumnReader.BaseDecimalColumnReader

Object
org.apache.parquet.io.api.Converter
org.apache.parquet.io.api.PrimitiveConverter
io.delta.kernel.defaults.internal.parquet.ParquetColumnReaders.BasePrimitiveColumnReader
io.delta.kernel.defaults.internal.parquet.DecimalColumnReader.BaseDecimalColumnReader
All Implemented Interfaces:
io.delta.kernel.defaults.internal.parquet.ParquetColumnReaders.BaseColumnReader
Direct Known Subclasses:
DecimalColumnReader.BinaryDictionaryAwareDecimalColumnReader, DecimalColumnReader.IntDictionaryAwareDecimalColumnReader, DecimalColumnReader.LongDictionaryAwareDecimalColumnReader
Enclosing class:
DecimalColumnReader

public abstract static class DecimalColumnReader.BaseDecimalColumnReader extends io.delta.kernel.defaults.internal.parquet.ParquetColumnReaders.BasePrimitiveColumnReader
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addValueFromDictionary(int dictionaryId)
     
    io.delta.kernel.data.ColumnVector
    getDataColumnVector(int batchSize)
     
    boolean
    Dictionary support is an optional optimization to reduce BigDecimal instantiation and binary decoding (for Binary backed decimals).
    void
     

    Methods inherited from class io.delta.kernel.defaults.internal.parquet.ParquetColumnReaders.BasePrimitiveColumnReader

    finalizeCurrentRow

    Methods inherited from class org.apache.parquet.io.api.PrimitiveConverter

    addBinary, addBoolean, addDouble, addFloat, addInt, addLong, asPrimitiveConverter, isPrimitive, setDictionary

    Methods inherited from class org.apache.parquet.io.api.Converter

    asGroupConverter

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface io.delta.kernel.defaults.internal.parquet.ParquetColumnReaders.BaseColumnReader

    resetWorkingState
  • Method Details

    • hasDictionarySupport

      public boolean hasDictionarySupport()
      Dictionary support is an optional optimization to reduce BigDecimal instantiation and binary decoding (for Binary backed decimals).
      Overrides:
      hasDictionarySupport in class org.apache.parquet.io.api.PrimitiveConverter
    • addValueFromDictionary

      public void addValueFromDictionary(int dictionaryId)
      Overrides:
      addValueFromDictionary in class org.apache.parquet.io.api.PrimitiveConverter
    • getDataColumnVector

      public io.delta.kernel.data.ColumnVector getDataColumnVector(int batchSize)
    • resizeIfNeeded

      public void resizeIfNeeded()