org.apache.paimon.format.parquet.newreader

Interface VectorizedValuesReader

All Known Implementing Classes:

VectorizedDeltaBinaryPackedReader, VectorizedDeltaByteArrayReader, VectorizedDeltaLengthByteArrayReader, VectorizedPlainValuesReader, VectorizedReaderBase, VectorizedRleValuesReader

public interface VectorizedValuesReader

Interface for value decoding that supports vectorized (aka batched) decoding.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	VectorizedValuesReader.ByteBufferOutputWriter A functional interface to write double values to columnar output.
static interface	VectorizedValuesReader.IntegerOutputWriter A functional interface to write integer values to columnar output.

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

Method Detail

readBoolean

boolean readBoolean()

readByte

byte readByte()

readShort

short readShort()

readInteger

int readInteger()

readLong

long readLong()

readFloat

float readFloat()

readDouble

double readDouble()

readBinary

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

readBooleans

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

readBytes

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

readShorts

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

readIntegers

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

readLongs

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

readFloats

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

readDoubles

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

readBinary

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

skipBooleans

void skipBooleans(int total)

skipBytes

void skipBytes(int total)

skipShorts

void skipShorts(int total)

skipIntegers

void skipIntegers(int total)

skipLongs

void skipLongs(int total)

skipFloats

void skipFloats(int total)

skipDoubles

void skipDoubles(int total)

skipBinary

void skipBinary(int total)

skipFixedLenByteArray

void skipFixedLenByteArray(int total,
                           int len)