org.apache.paimon.format.parquet.newreader

Class VectorizedReaderBase

java.lang.Object

org.apache.parquet.column.values.ValuesReader

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

All Implemented Interfaces:

VectorizedValuesReader

Direct Known Subclasses:

VectorizedDeltaBinaryPackedReader, VectorizedDeltaByteArrayReader, VectorizedDeltaLengthByteArrayReader

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

Base class for implementations of VectorizedValuesReader. Mainly to avoid duplication of methods that are not supported by concrete implementations

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

Method Summary

Modifier and Type	Method and Description
org.apache.parquet.io.api.Binary	readBinary(int len)
void	readBinary(int total, WritableBytesVector c, int rowId)
void	readBooleans(int total, WritableBooleanVector c, int rowId)
byte	readByte()
void	readBytes(int total, WritableByteVector c, int rowId)
void	readDoubles(int total, WritableDoubleVector c, int rowId)
void	readFloats(int total, WritableFloatVector c, int rowId)
void	readIntegers(int total, WritableIntVector c, int rowId)
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, 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

readBoolean, readDouble, readFloat, readInteger, readLong

Constructor Detail

VectorizedReaderBase

public VectorizedReaderBase()

Method Detail

skip

public void skip()

Specified by:

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

readByte

public byte readByte()

Specified by:

readByte in interface VectorizedValuesReader

readShort

public short readShort()

Specified by:

readShort in interface VectorizedValuesReader

readBinary

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

Specified by:

readBinary in interface VectorizedValuesReader

readBooleans

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

Specified by:

readBooleans in interface VectorizedValuesReader

readBytes

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

Specified by:

readBytes in interface VectorizedValuesReader

readShorts

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

Specified by:

readShorts in interface VectorizedValuesReader

readIntegers

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

Specified by:

readIntegers in interface VectorizedValuesReader

readLongs

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

Specified by:

readLongs in interface VectorizedValuesReader

readFloats

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

Specified by:

readFloats in interface VectorizedValuesReader

readDoubles

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

Specified by:

readDoubles in interface VectorizedValuesReader

readBinary

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

Specified by:

readBinary in interface VectorizedValuesReader

skipBooleans

public void skipBooleans(int total)

Specified by:

skipBooleans in interface VectorizedValuesReader

skipBytes

public void skipBytes(int total)

Specified by:

skipBytes in interface VectorizedValuesReader

skipShorts

public void skipShorts(int total)

Specified by:

skipShorts in interface VectorizedValuesReader

skipIntegers

public void skipIntegers(int total)

Specified by:

skipIntegers in interface VectorizedValuesReader

skipLongs

public void skipLongs(int total)

Specified by:

skipLongs in interface VectorizedValuesReader

skipFloats

public void skipFloats(int total)

Specified by:

skipFloats in interface VectorizedValuesReader

skipDoubles

public void skipDoubles(int total)

Specified by:

skipDoubles in interface VectorizedValuesReader

skipBinary

public void skipBinary(int total)

Specified by:

skipBinary in interface VectorizedValuesReader

skipFixedLenByteArray

public void skipFixedLenByteArray(int total,
                                  int len)

Specified by:

skipFixedLenByteArray in interface VectorizedValuesReader