org.apache.iceberg.arrow.vectorized.parquet

Class VectorizedDictionaryEncodedParquetValuesReader

java.lang.Object

org.apache.parquet.column.values.ValuesReader

org.apache.iceberg.arrow.vectorized.parquet.BaseVectorizedParquetValuesReader

org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader

public class VectorizedDictionaryEncodedParquetValuesReader
extends BaseVectorizedParquetValuesReader

This decoder reads Parquet dictionary encoded data in a vectorized fashion. Unlike other vectorized readers, methods in this decoder don't need to read definition levels. In other words, these methods are called when there are non-null values to be read.

Constructor Summary

Constructors

Constructor and Description
VectorizedDictionaryEncodedParquetValuesReader(int maxDefLevel, boolean setValidityVector)

Method Summary

Modifier and Type	Method and Description
org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.DictionaryIdReader	dictionaryIdReader()
org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.DoubleDictEncodedReader	doubleDictEncodedReader()
org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.FixedLengthDecimalDictEncodedReader	fixedLengthDecimalDictEncodedReader()
org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.FixedSizeBinaryDictEncodedReader	fixedSizeBinaryDictEncodedReader()
org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.FixedWidthBinaryDictEncodedReader	fixedWidthBinaryDictEncodedReader()
org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.FloatDictEncodedReader	floatDictEncodedReader()
org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.IntBackedDecimalDictEncodedReader	intBackedDecimalDictEncodedReader()
org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.IntegerDictEncodedReader	integerDictEncodedReader()
org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.LongBackedDecimalDictEncodedReader	longBackedDecimalDictEncodedReader()
org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.LongDictEncodedReader	longDictEncodedReader()
org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.TimestampInt96DictEncodedReader	timestampInt96DictEncodedReader()
org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.TimestampMillisDictEncodedReader	timestampMillisDictEncodedReader()
org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.VarWidthBinaryDictEncodedReader	varWidthBinaryDictEncodedReader()

Methods inherited from class org.apache.iceberg.arrow.vectorized.parquet.BaseVectorizedParquetValuesReader

initFromPage, readBoolean, readInteger, readValueDictionaryId, skip

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

getNextOffset, initFromPage, initFromPage, readBytes, readDouble, readFloat, readLong, skip, updateNextOffset

Methods inherited from class java.lang.Object

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

Constructor Detail

VectorizedDictionaryEncodedParquetValuesReader

public VectorizedDictionaryEncodedParquetValuesReader(int maxDefLevel,
                                                      boolean setValidityVector)

Method Detail

dictionaryIdReader

public org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.DictionaryIdReader dictionaryIdReader()

longDictEncodedReader

public org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.LongDictEncodedReader longDictEncodedReader()

timestampMillisDictEncodedReader

public org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.TimestampMillisDictEncodedReader timestampMillisDictEncodedReader()

timestampInt96DictEncodedReader

public org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.TimestampInt96DictEncodedReader timestampInt96DictEncodedReader()

integerDictEncodedReader

public org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.IntegerDictEncodedReader integerDictEncodedReader()

floatDictEncodedReader

public org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.FloatDictEncodedReader floatDictEncodedReader()

doubleDictEncodedReader

public org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.DoubleDictEncodedReader doubleDictEncodedReader()

fixedWidthBinaryDictEncodedReader

public org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.FixedWidthBinaryDictEncodedReader fixedWidthBinaryDictEncodedReader()

fixedLengthDecimalDictEncodedReader

public org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.FixedLengthDecimalDictEncodedReader fixedLengthDecimalDictEncodedReader()

varWidthBinaryDictEncodedReader

public org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.VarWidthBinaryDictEncodedReader varWidthBinaryDictEncodedReader()

intBackedDecimalDictEncodedReader

public org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.IntBackedDecimalDictEncodedReader intBackedDecimalDictEncodedReader()

longBackedDecimalDictEncodedReader

public org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.LongBackedDecimalDictEncodedReader longBackedDecimalDictEncodedReader()

fixedSizeBinaryDictEncodedReader

public org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.FixedSizeBinaryDictEncodedReader fixedSizeBinaryDictEncodedReader()