org.apache.paimon.data.columnar.heap

Class HeapIntVector

java.lang.Object

org.apache.paimon.data.columnar.writable.AbstractWritableVector

org.apache.paimon.data.columnar.heap.AbstractHeapVector

org.apache.paimon.data.columnar.heap.HeapIntVector

All Implemented Interfaces:

Serializable, ColumnVector, ElementCountable, IntColumnVector, WritableColumnVector, WritableIntVector

public class HeapIntVector
extends AbstractHeapVector
implements WritableIntVector

This class represents a nullable int column vector.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
int[]	vector

Fields inherited from class org.apache.paimon.data.columnar.heap.AbstractHeapVector

BYTE_ARRAY_OFFSET, dictionaryIds, DOUBLE_ARRAY_OFFSET, FLOAT_ARRAY_OFFSET, INT_ARRAY_OFFSET, isNull, LITTLE_ENDIAN, LONG_ARRAY_OFFSET, UNSAFE

Fields inherited from class org.apache.paimon.data.columnar.writable.AbstractWritableVector

capacity, dictionary, elementsAppended, isAllNull, noNulls

Constructor Summary

Constructors

Constructor and Description
HeapIntVector(int len) Don't use this except for testing purposes.

Method Summary

Modifier and Type	Method and Description
void	appendInt(int v)
void	appendInts(int count, int v)
void	fill(int value) Fill the column vector with the provided value.
int	getInt(int i)
void	reset() Resets the column to default state.
void	setInt(int i, int value) Set int at rowId with the provided value.
void	setInts(int rowId, int count, int value) Sets value to [rowId, rowId + count) by the value, this is data that repeats continuously.
void	setInts(int rowId, int count, int[] src, int srcIndex) Sets values from [src[srcIndex], src[srcIndex + count]) to [rowId, rowId + count).
void	setIntsFromBinary(int rowId, int count, byte[] src, int srcIndex) Set ints from binary, need use UNSAFE to copy.
void	setNullAt(int i) Set null at rowId.

Methods inherited from class org.apache.paimon.data.columnar.heap.AbstractHeapVector

fillWithNulls, getDictionaryIds, isNullAt, reserveDictionaryIds, reserveInternal, setNulls

Methods inherited from class org.apache.paimon.data.columnar.writable.AbstractWritableVector

addElementsAppended, getCapacity, getElementsAppended, hasDictionary, isAllNull, reserve, setAllNull, setDictionary

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.data.columnar.writable.WritableColumnVector

addElementsAppended, fillWithNulls, getDictionaryIds, getElementsAppended, hasDictionary, isAllNull, reserve, reserveAdditional, reserveDictionaryIds, setAllNull, setDictionary, setNulls

Methods inherited from interface org.apache.paimon.data.columnar.ColumnVector

getCapacity, getChildren, isNullAt

Methods inherited from interface org.apache.paimon.data.columnar.heap.ElementCountable

getCapacity

Field Detail

vector

public int[] vector

Constructor Detail

HeapIntVector

public HeapIntVector(int len)

Don't use this except for testing purposes.

Parameters:

len - the number of rows

Method Detail

setNullAt

public void setNullAt(int i)

Description copied from interface: WritableColumnVector

Set null at rowId.

Specified by:

setNullAt in interface WritableColumnVector

Overrides:

setNullAt in class AbstractHeapVector

getInt

public int getInt(int i)

Specified by:

getInt in interface IntColumnVector

setInt

public void setInt(int i,
                   int value)

Description copied from interface: WritableIntVector

Set int at rowId with the provided value.

Specified by:

setInt in interface WritableIntVector

setIntsFromBinary

public void setIntsFromBinary(int rowId,
                              int count,
                              byte[] src,
                              int srcIndex)

Description copied from interface: WritableIntVector

Set ints from binary, need use UNSAFE to copy.

Specified by:

setIntsFromBinary in interface WritableIntVector

Parameters:

rowId - set start rowId.

count - count for int, so the bytes size is count * 4.

src - source binary.

srcIndex - source binary index, it is the index for byte index.

setInts

public void setInts(int rowId,
                    int count,
                    int value)

Description copied from interface: WritableIntVector

Sets value to [rowId, rowId + count) by the value, this is data that repeats continuously.

Specified by:

setInts in interface WritableIntVector

setInts

public void setInts(int rowId,
                    int count,
                    int[] src,
                    int srcIndex)

Description copied from interface: WritableIntVector

Sets values from [src[srcIndex], src[srcIndex + count]) to [rowId, rowId + count).

Specified by:

setInts in interface WritableIntVector

fill

public void fill(int value)

Description copied from interface: WritableIntVector

Fill the column vector with the provided value.

Specified by:

fill in interface WritableIntVector

appendInt

public void appendInt(int v)

Specified by:

appendInt in interface WritableIntVector

appendInts

public void appendInts(int count,
                       int v)

Specified by:

appendInts in interface WritableIntVector

reset

public void reset()

Description copied from class: AbstractHeapVector

Resets the column to default state. - fills the isNull array with false.

Specified by:

reset in interface WritableColumnVector

Overrides:

reset in class AbstractHeapVector