org.apache.paimon.format.parquet.newreader

Class VectorizedPlainValuesReader

java.lang.Object

org.apache.parquet.column.values.ValuesReader

org.apache.paimon.format.parquet.newreader.VectorizedPlainValuesReader

All Implemented Interfaces:

VectorizedValuesReader

public class VectorizedPlainValuesReader
extends org.apache.parquet.column.values.ValuesReader
implements VectorizedValuesReader

An implementation of the Parquet PLAIN 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

Constructor Summary

Constructors

Constructor and Description
VectorizedPlainValuesReader()

Method Summary

Modifier and Type	Method and Description
void	initFromPage(int valueCount, org.apache.parquet.bytes.ByteBufferInputStream in)
org.apache.parquet.io.api.Binary	readBinary(int len)
void	readBinary(int total, WritableBytesVector v, int rowId)
boolean	readBoolean()
void	readBooleans(int total, WritableBooleanVector c, int rowId)
byte	readByte()
void	readBytes(int total, WritableByteVector c, int rowId)
double	readDouble()
void	readDoubles(int total, WritableDoubleVector c, int rowId)
float	readFloat()
void	readFloats(int total, WritableFloatVector 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	skip()
void	skipBinary(int total)
void	skipBooleans(int total)
void	skipBytes(int total)
void	skipDoubles(int total)
void	skipFixedLenByteArray(int total, int len)
void	skipFloats(int total)
void	skipIntegers(int total)
void	skipLongs(int total)
void	skipShorts(int total)

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

getNextOffset, initFromPage, initFromPage, readBytes, readValueDictionaryId, skip, updateNextOffset

Methods inherited from class java.lang.Object

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

Constructor Detail

VectorizedPlainValuesReader

public VectorizedPlainValuesReader()

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

skip

public void skip()

Specified by:

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

readBooleans

public final void readBooleans(int total,
                               WritableBooleanVector c,
                               int rowId)

Specified by:

readBooleans in interface VectorizedValuesReader

skipBooleans

public final void skipBooleans(int total)

Specified by:

skipBooleans in interface VectorizedValuesReader

readIntegers

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

Specified by:

readIntegers in interface VectorizedValuesReader

skipIntegers

public void skipIntegers(int total)

Specified by:

skipIntegers in interface VectorizedValuesReader

readLongs

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

Specified by:

readLongs in interface VectorizedValuesReader

skipLongs

public void skipLongs(int total)

Specified by:

skipLongs in interface VectorizedValuesReader

readFloats

public final void readFloats(int total,
                             WritableFloatVector c,
                             int rowId)

Specified by:

readFloats in interface VectorizedValuesReader

skipFloats

public void skipFloats(int total)

Specified by:

skipFloats in interface VectorizedValuesReader

readDoubles

public final void readDoubles(int total,
                              WritableDoubleVector c,
                              int rowId)

Specified by:

readDoubles in interface VectorizedValuesReader

skipDoubles

public void skipDoubles(int total)

Specified by:

skipDoubles in interface VectorizedValuesReader

readBytes

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

Specified by:

readBytes in interface VectorizedValuesReader

skipBytes

public final void skipBytes(int total)

Specified by:

skipBytes in interface VectorizedValuesReader

readShorts

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

Specified by:

readShorts in interface VectorizedValuesReader

skipShorts

public void skipShorts(int total)

Specified by:

skipShorts in interface VectorizedValuesReader

readBoolean

public final boolean readBoolean()

Specified by:

readBoolean in interface VectorizedValuesReader

Overrides:

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

readInteger

public final int readInteger()

Specified by:

readInteger in interface VectorizedValuesReader

Overrides:

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

readLong

public final long readLong()

Specified by:

readLong in interface VectorizedValuesReader

Overrides:

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

readByte

public final byte readByte()

Specified by:

readByte in interface VectorizedValuesReader

readShort

public short readShort()

Specified by:

readShort in interface VectorizedValuesReader

readFloat

public final float readFloat()

Specified by:

readFloat in interface VectorizedValuesReader

Overrides:

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

readDouble

public final double readDouble()

Specified by:

readDouble in interface VectorizedValuesReader

Overrides:

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

readBinary

public final void readBinary(int total,
                             WritableBytesVector v,
                             int rowId)

Specified by:

readBinary in interface VectorizedValuesReader

skipBinary

public void skipBinary(int total)

Specified by:

skipBinary in interface VectorizedValuesReader

readBinary

public final org.apache.parquet.io.api.Binary readBinary(int len)

Specified by:

readBinary in interface VectorizedValuesReader

skipFixedLenByteArray

public void skipFixedLenByteArray(int total,
                                  int len)

Specified by:

skipFixedLenByteArray in interface VectorizedValuesReader