@Internal public abstract class AbstractHeapVector extends AbstractWritableVector
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 |
dictionary, noNulls
Constructor and Description |
---|
AbstractHeapVector(int len) |
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.
|
int |
getLen() |
boolean |
isNullAt(int i) |
HeapIntVector |
reserveDictionaryIds(int capacity)
Reserve a integer column for ids of dictionary.
|
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).
|
hasDictionary, setDictionary
public static final boolean LITTLE_ENDIAN
public static final sun.misc.Unsafe UNSAFE
public static final int BYTE_ARRAY_OFFSET
public static final int INT_ARRAY_OFFSET
public static final int LONG_ARRAY_OFFSET
public static final int FLOAT_ARRAY_OFFSET
public static final int DOUBLE_ARRAY_OFFSET
protected boolean[] isNull
protected HeapIntVector dictionaryIds
public void reset()
public void setNullAt(int i)
WritableColumnVector
public void setNulls(int i, int count)
WritableColumnVector
public void fillWithNulls()
WritableColumnVector
public boolean isNullAt(int i)
public HeapIntVector reserveDictionaryIds(int capacity)
WritableColumnVector
WritableIntVector
should be equal to or bigger than capacity. DictionaryIds must inconsistent with WritableColumnVector.setDictionary(org.apache.flink.table.data.columnar.vector.Dictionary)
. We don't support a mix of dictionary.public HeapIntVector getDictionaryIds()
public int getLen()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.