Uses of Interface
org.apache.paimon.data.columnar.writable.WritableIntVector

Packages that use WritableIntVector

Package	Description
org.apache.paimon.data.columnar.heap
org.apache.paimon.data.columnar.writable
org.apache.paimon.format.parquet.newreader
org.apache.paimon.format.parquet.reader

Uses of WritableIntVector in org.apache.paimon.data.columnar.heap

Classes in org.apache.paimon.data.columnar.heap that implement WritableIntVector

Modifier and Type	Class and Description
class	HeapIntVector This class represents a nullable int column vector.

Uses of WritableIntVector in org.apache.paimon.data.columnar.writable

Methods in org.apache.paimon.data.columnar.writable that return WritableIntVector

Modifier and Type	Method and Description
WritableIntVector	WritableColumnVector.getDictionaryIds() Get reserved dictionary ids.
WritableIntVector	WritableColumnVector.reserveDictionaryIds(int capacity) Reserve a integer column for ids of dictionary.

Uses of WritableIntVector in org.apache.paimon.format.parquet.newreader

Methods in org.apache.paimon.format.parquet.newreader with parameters of type WritableIntVector

Modifier and Type	Method and Description
default void	ParquetVectorUpdater.decodeDictionaryIds(int total, int offset, T values, WritableIntVector dictionaryIds, org.apache.parquet.column.Dictionary dictionary) Process a batch of `total` values starting from `offset` in `values`, whose null slots should have already been filled, and fills the non-null slots using dictionary IDs from `dictionaryIds`, together with Parquet `dictionary`.
void	ParquetVectorUpdater.decodeSingleDictionaryId(int offset, T values, WritableIntVector dictionaryIds, org.apache.parquet.column.Dictionary dictionary) Decode a single dictionary ID from `dictionaryIds` into `values` at `offset`, using `dictionary`.
void	VectorizedRleValuesReader.readBatch(ParquetReadState state, WritableColumnVector values, WritableIntVector defLevels, VectorizedValuesReader valueReader, ParquetVectorUpdater updater) Reads a batch of definition levels and values into vector 'defLevels' and 'values' respectively.
void	VectorizedRleValuesReader.readBatchRepeated(ParquetReadState state, WritableIntVector repLevels, VectorizedRleValuesReader defLevelsReader, WritableIntVector defLevels, WritableColumnVector values, VectorizedValuesReader valueReader, ParquetVectorUpdater updater) Reads a batch of repetition levels, definition levels and values into 'repLevels', 'defLevels' and 'values' respectively.
void	VectorizedRleValuesReader.readBatchRepeatedInternal(ParquetReadState state, WritableIntVector repLevels, VectorizedRleValuesReader defLevelsReader, WritableIntVector defLevels, WritableColumnVector values, WritableColumnVector nulls, boolean valuesReused, VectorizedValuesReader valueReader, ParquetVectorUpdater updater) Keep reading repetition level values from the page until either: 1) we've read enough top-level rows to fill the current batch, or 2) we've drained the data page completely.
void	VectorizedRleValuesReader.readIntegers(int total, WritableIntVector c, int rowId)
void	VectorizedValuesReader.readIntegers(int total, WritableIntVector c, int rowId)
void	VectorizedPlainValuesReader.readIntegers(int total, WritableIntVector c, int rowId)
void	VectorizedReaderBase.readIntegers(int total, WritableIntVector c, int rowId)
void	VectorizedDeltaBinaryPackedReader.readIntegers(int total, WritableIntVector c, int rowId)
void	VectorizedRleValuesReader.readIntegers(ParquetReadState state, WritableColumnVector values, WritableColumnVector nulls, WritableIntVector defLevels, VectorizedValuesReader valueReader) Decoding for dictionary ids.
void	VectorizedRleValuesReader.readIntegersRepeated(ParquetReadState state, WritableIntVector repLevels, VectorizedRleValuesReader defLevelsReader, WritableIntVector defLevels, WritableColumnVector values, WritableColumnVector nulls, VectorizedValuesReader valueReader) Reads a batch of repetition levels, definition levels and integer values into 'repLevels', 'defLevels', 'values' and 'nulls' respectively.

Uses of WritableIntVector in org.apache.paimon.format.parquet.reader

Classes in org.apache.paimon.format.parquet.reader that implement WritableIntVector

Modifier and Type	Class and Description
class	ParquetDecimalVector Parquet write decimal as int32 and int64 and binary, this class wrap the real vector to provide DecimalColumnVector interface.

Methods in org.apache.paimon.format.parquet.reader that return WritableIntVector

Modifier and Type	Method and Description
WritableIntVector	ParquetDecimalVector.getDictionaryIds()
WritableIntVector	ParquetDecimalVector.reserveDictionaryIds(int capacity)

Methods in org.apache.paimon.format.parquet.reader with parameters of type WritableIntVector

Modifier and Type	Method and Description
protected void	IntColumnReader.readBatch(int rowId, int num, WritableIntVector column)
protected void	FixedLenBytesBinaryColumnReader.readBatchFromDictionaryIds(int rowId, int num, VECTOR column, WritableIntVector dictionaryIds)
protected void	FixedLenBytesDecimalColumnReader.readBatchFromDictionaryIds(int rowId, int num, VECTOR column, WritableIntVector dictionaryIds)
protected abstract void	AbstractColumnReader.readBatchFromDictionaryIds(int rowId, int num, VECTOR column, WritableIntVector dictionaryIds) Decode dictionary ids to data.
protected void	BooleanColumnReader.readBatchFromDictionaryIds(int rowId, int num, WritableBooleanVector column, WritableIntVector dictionaryIds)
protected void	BytesColumnReader.readBatchFromDictionaryIds(int rowId, int num, WritableBytesVector column, WritableIntVector dictionaryIds)
protected void	ByteColumnReader.readBatchFromDictionaryIds(int rowId, int num, WritableByteVector column, WritableIntVector dictionaryIds)
protected void	DoubleColumnReader.readBatchFromDictionaryIds(int rowId, int num, WritableDoubleVector column, WritableIntVector dictionaryIds)
protected void	FloatColumnReader.readBatchFromDictionaryIds(int rowId, int num, WritableFloatVector column, WritableIntVector dictionaryIds)
protected void	IntColumnReader.readBatchFromDictionaryIds(int rowId, int num, WritableIntVector column, WritableIntVector dictionaryIds)
protected void	LongColumnReader.readBatchFromDictionaryIds(int rowId, int num, WritableLongVector column, WritableIntVector dictionaryIds)
protected void	ShortColumnReader.readBatchFromDictionaryIds(int rowId, int num, WritableShortVector column, WritableIntVector dictionaryIds)
protected void	TimestampColumnReader.readBatchFromDictionaryIds(int rowId, int num, WritableTimestampVector column, WritableIntVector dictionaryIds)