org.apache.paimon.data.columnar.heap

Class AbstractHeapVector

java.lang.Object

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

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

All Implemented Interfaces:

Serializable, ColumnVector, ElementCountable, WritableColumnVector

Direct Known Subclasses:

AbstractStructVector, HeapBooleanVector, HeapBytesVector, HeapByteVector, HeapDoubleVector, HeapFloatVector, HeapIntVector, HeapLongVector, HeapShortVector, HeapTimestampVector

public abstract class AbstractHeapVector
extends AbstractWritableVector
implements ElementCountable

Heap vector that nullable shared structure.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static int	BYTE_ARRAY_OFFSET
protected HeapIntVector	dictionaryIds Reusable column for ids of dictionary.
static int	DOUBLE_ARRAY_OFFSET
static int	FLOAT_ARRAY_OFFSET
static int	INT_ARRAY_OFFSET
protected boolean[]	isNull
static boolean	LITTLE_ENDIAN
static int	LONG_ARRAY_OFFSET
static sun.misc.Unsafe	UNSAFE

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

capacity, dictionary, elementsAppended, isAllNull, noNulls

Constructor Summary

Constructors

Constructor and Description
AbstractHeapVector(int capacity)

Method Summary

Modifier and Type	Method and Description
void	fillWithNulls() Fill the column vector with nulls.
HeapIntVector	getDictionaryIds() Returns the underlying integer column for ids of dictionary.
boolean	isNullAt(int i)
HeapIntVector	reserveDictionaryIds(int capacity) Reserve a integer column for ids of dictionary.
protected void	reserveInternal(int newCapacity)
void	reset() Resets the column to default state.
void	setNullAt(int i) Set null at rowId.
void	setNulls(int i, int count) Set nulls from rowId to rowId + count (exclude).

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.heap.ElementCountable

getCapacity

Methods inherited from interface org.apache.paimon.data.columnar.writable.WritableColumnVector

reserveAdditional

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

getChildren

Field Detail

LITTLE_ENDIAN

public static final boolean LITTLE_ENDIAN

UNSAFE

public static final sun.misc.Unsafe UNSAFE

BYTE_ARRAY_OFFSET

public static final int BYTE_ARRAY_OFFSET

INT_ARRAY_OFFSET

public static final int INT_ARRAY_OFFSET

LONG_ARRAY_OFFSET

public static final int LONG_ARRAY_OFFSET

FLOAT_ARRAY_OFFSET

public static final int FLOAT_ARRAY_OFFSET

DOUBLE_ARRAY_OFFSET

public static final int DOUBLE_ARRAY_OFFSET

isNull

protected boolean[] isNull

dictionaryIds

protected HeapIntVector dictionaryIds

Reusable column for ids of dictionary.

Constructor Detail

AbstractHeapVector

public AbstractHeapVector(int capacity)

Method Detail

reset

public void reset()

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

Specified by:

reset in interface WritableColumnVector

Overrides:

reset in class AbstractWritableVector

setNullAt

public void setNullAt(int i)

Description copied from interface: WritableColumnVector

Set null at rowId.

Specified by:

setNullAt in interface WritableColumnVector

setNulls

public void setNulls(int i,
                     int count)

Description copied from interface: WritableColumnVector

Set nulls from rowId to rowId + count (exclude).

Specified by:

setNulls in interface WritableColumnVector

fillWithNulls

public void fillWithNulls()

Description copied from interface: WritableColumnVector

Fill the column vector with nulls.

Specified by:

fillWithNulls in interface WritableColumnVector

isNullAt

public boolean isNullAt(int i)

Specified by:

isNullAt in interface ColumnVector

reserveDictionaryIds

public HeapIntVector reserveDictionaryIds(int capacity)

Description copied from interface: WritableColumnVector

Reserve a integer column for ids of dictionary. The size of return WritableIntVector should be equal to or bigger than capacity. DictionaryIds must inconsistent with WritableColumnVector.setDictionary(org.apache.paimon.data.columnar.Dictionary). We don't support a mix of dictionary.

Specified by:

reserveDictionaryIds in interface WritableColumnVector

getDictionaryIds

public HeapIntVector getDictionaryIds()

Returns the underlying integer column for ids of dictionary.

Specified by:

getDictionaryIds in interface WritableColumnVector

reserveInternal

protected void reserveInternal(int newCapacity)

Specified by:

reserveInternal in class AbstractWritableVector