org.apache.paimon.format.parquet.newreader

Class VectorizedDeltaBinaryPackedReader

java.lang.Object

org.apache.parquet.column.values.ValuesReader

org.apache.paimon.format.parquet.newreader.VectorizedReaderBase

org.apache.paimon.format.parquet.newreader.VectorizedDeltaBinaryPackedReader

All Implemented Interfaces:

VectorizedValuesReader

public class VectorizedDeltaBinaryPackedReader
extends VectorizedReaderBase

An implementation of the Parquet DELTA_BINARY_PACKED decoder that supports the vectorized interface. DELTA_BINARY_PACKED is a delta encoding for integer and long types that stores values as a delta between consecutive values. Delta values are themselves bit packed. Similar to RLE but is more effective in the case of large variation of values in the encoded column.

DELTA_BINARY_PACKED is the default encoding for integer and long columns in Parquet V2.

Supported Types: INT32, INT64

@see Parquet format encodings: DELTA_BINARY_PACKED

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.format.parquet.newreader.VectorizedValuesReader

VectorizedValuesReader.ByteBufferOutputWriter, VectorizedValuesReader.IntegerOutputWriter

Constructor Summary

Constructors

Constructor and Description
VectorizedDeltaBinaryPackedReader()

Method Summary

Modifier and Type	Method and Description
void	initFromPage(int valueCount, org.apache.parquet.bytes.ByteBufferInputStream in)
byte	readByte()
void	readBytes(int total, WritableByteVector c, int rowId)
int	readInteger()
void	readIntegers(int total, WritableIntVector c, int rowId)
long	readLong()
void	readLongs(int total, WritableLongVector c, int rowId)
short	readShort()
void	readShorts(int total, WritableShortVector c, int rowId)
void	skipBytes(int total)
void	skipIntegers(int total)
void	skipLongs(int total)
void	skipShorts(int total)

Methods inherited from class org.apache.paimon.format.parquet.newreader.VectorizedReaderBase

readBinary, readBinary, readBooleans, readDoubles, readFloats, skip, skipBinary, skipBooleans, skipDoubles, skipFixedLenByteArray, skipFloats

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

Methods inherited from interface org.apache.paimon.format.parquet.newreader.VectorizedValuesReader

readBoolean, readDouble, readFloat

Constructor Detail

VectorizedDeltaBinaryPackedReader

public VectorizedDeltaBinaryPackedReader()

Method Detail

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

readByte

public byte readByte()

Specified by:

readByte in interface VectorizedValuesReader

Overrides:

readByte in class VectorizedReaderBase

readShort

public short readShort()

Specified by:

readShort in interface VectorizedValuesReader

Overrides:

readShort in class VectorizedReaderBase

readInteger

public int readInteger()

Specified by:

readInteger in interface VectorizedValuesReader

Overrides:

readInteger in class org.apache.parquet.column.values.ValuesReader

readLong

public long readLong()

Specified by:

readLong in interface VectorizedValuesReader

Overrides:

readLong in class org.apache.parquet.column.values.ValuesReader

readBytes

public void readBytes(int total,
                      WritableByteVector c,
                      int rowId)

Specified by:

readBytes in interface VectorizedValuesReader

Overrides:

readBytes in class VectorizedReaderBase

readShorts

public void readShorts(int total,
                       WritableShortVector c,
                       int rowId)

Specified by:

readShorts in interface VectorizedValuesReader

Overrides:

readShorts in class VectorizedReaderBase

readIntegers

public void readIntegers(int total,
                         WritableIntVector c,
                         int rowId)

Specified by:

readIntegers in interface VectorizedValuesReader

Overrides:

readIntegers in class VectorizedReaderBase

readLongs

public void readLongs(int total,
                      WritableLongVector c,
                      int rowId)

Specified by:

readLongs in interface VectorizedValuesReader

Overrides:

readLongs in class VectorizedReaderBase

skipBytes

public void skipBytes(int total)

Specified by:

skipBytes in interface VectorizedValuesReader

Overrides:

skipBytes in class VectorizedReaderBase

skipShorts

public void skipShorts(int total)

Specified by:

skipShorts in interface VectorizedValuesReader

Overrides:

skipShorts in class VectorizedReaderBase

skipIntegers

public void skipIntegers(int total)

Specified by:

skipIntegers in interface VectorizedValuesReader

Overrides:

skipIntegers in class VectorizedReaderBase

skipLongs

public void skipLongs(int total)

Specified by:

skipLongs in interface VectorizedValuesReader

Overrides:

skipLongs in class VectorizedReaderBase