org.apache.paimon.format.parquet.newreader

Class VectorizedDeltaLengthByteArrayReader

java.lang.Object

org.apache.parquet.column.values.ValuesReader

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

org.apache.paimon.format.parquet.newreader.VectorizedDeltaLengthByteArrayReader

All Implemented Interfaces:

VectorizedValuesReader

public class VectorizedDeltaLengthByteArrayReader
extends VectorizedReaderBase
implements VectorizedValuesReader

An implementation of the Parquet DELTA_LENGTH_BYTE_ARRAY decoder that supports the vectorized interface.

Nested Class Summary

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

VectorizedValuesReader.ByteBufferOutputWriter, VectorizedValuesReader.IntegerOutputWriter

Method Summary

Modifier and Type	Method and Description
ByteBuffer	getBytes(int rowId)
void	initFromPage(int valueCount, org.apache.parquet.bytes.ByteBufferInputStream in)
void	readBinary(int total, WritableBytesVector c, int rowId)
void	skipBinary(int total)

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

readBinary, readBooleans, readByte, readBytes, readDoubles, readFloats, readIntegers, readLongs, readShort, readShorts, skip, skipBooleans, skipBytes, skipDoubles, skipFixedLenByteArray, skipFloats, skipIntegers, skipLongs, skipShorts

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

getNextOffset, initFromPage, initFromPage, readBoolean, readBytes, readDouble, readFloat, readInteger, readLong, 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

readBinary, readBoolean, readBooleans, readByte, readBytes, readDouble, readDoubles, readFloat, readFloats, readInteger, readIntegers, readLong, readLongs, readShort, readShorts, skipBooleans, skipBytes, skipDoubles, skipFixedLenByteArray, skipFloats, skipIntegers, skipLongs, skipShorts

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

readBinary

public void readBinary(int total,
                       WritableBytesVector c,
                       int rowId)

Specified by:

readBinary in interface VectorizedValuesReader

Overrides:

readBinary in class VectorizedReaderBase

getBytes

public ByteBuffer getBytes(int rowId)

skipBinary

public void skipBinary(int total)

Specified by:

skipBinary in interface VectorizedValuesReader

Overrides:

skipBinary in class VectorizedReaderBase