Interface WritableIntVector
-
- All Superinterfaces:
ColumnVector
,IntColumnVector
,WritableColumnVector
- All Known Implementing Classes:
HeapIntVector
,ParquetDecimalVector
@Internal public interface WritableIntVector extends WritableColumnVector, IntColumnVector
WritableIntColumnVector
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
fill(int value)
Fill the column vector with the provided value.void
setInt(int rowId, 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.-
Methods inherited from interface org.apache.flink.table.data.columnar.vector.ColumnVector
isNullAt
-
Methods inherited from interface org.apache.flink.table.data.columnar.vector.IntColumnVector
getInt
-
Methods inherited from interface org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector
fillWithNulls, getDictionaryIds, hasDictionary, reserveDictionaryIds, reset, setDictionary, setNullAt, setNulls
-
-
-
-
Method Detail
-
setInt
void setInt(int rowId, int value)
Set int at rowId with the provided value.
-
setIntsFromBinary
void setIntsFromBinary(int rowId, int count, byte[] src, int srcIndex)
Set ints from binary, need use UNSAFE to copy.- 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
void setInts(int rowId, int count, int value)
Sets value to [rowId, rowId + count) by the value, this is data that repeats continuously.
-
setInts
void setInts(int rowId, int count, int[] src, int srcIndex)
Sets values from [src[srcIndex], src[srcIndex + count]) to [rowId, rowId + count).
-
fill
void fill(int value)
Fill the column vector with the provided value.
-
-