Package 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	Description
VectorizedDictionaryEncodedParquetValuesReader(int maxDefLevel, boolean setValidityVector)

Method Summary

Modifier and Type	Method	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.FixedSizeBinaryDictEncodedReader	fixedSizeBinaryDictEncodedReader()
org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.FloatDictEncodedReader	floatDictEncodedReader()
org.apache.iceberg.arrow.vectorized.parquet.VectorizedDictionaryEncodedParquetValuesReader.IntegerDictEncodedReader	integerDictEncodedReader()
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 Details

VectorizedDictionaryEncodedParquetValuesReader

public VectorizedDictionaryEncodedParquetValuesReader(int maxDefLevel,
 boolean setValidityVector)

Method Details

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

varWidthBinaryDictEncodedReader

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

fixedSizeBinaryDictEncodedReader

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