org
.
apache
.
spark
.
sql
.
execution
.
vectorized
ColumnVector
Related Doc:
package vectorized
abstract
class
ColumnVector
extends
AutoCloseable
Linear Supertypes
AutoCloseable
,
AnyRef
,
Any
Known Subclasses
OffHeapColumnVector
,
OnHeapColumnVector
Ordering
Alphabetic
By Inheritance
Inherited
ColumnVector
AutoCloseable
AnyRef
Any
Hide All
Show All
Visibility
Public
All
Instance Constructors
new
ColumnVector
(
capacity:
Int
,
type:
DataType
,
memMode:
MemoryMode
)
Attributes
protected[
org.apache.spark.sql.execution.vectorized
]
Abstract Value Members
abstract
def
close
()
:
Unit
Definition Classes
ColumnVector
→ AutoCloseable
abstract
def
getArrayLength
(
rowId:
Int
)
:
Int
abstract
def
getArrayOffset
(
rowId:
Int
)
:
Int
abstract
def
getBoolean
(
rowId:
Int
)
:
Boolean
abstract
def
getByte
(
rowId:
Int
)
:
Byte
abstract
def
getDictId
(
rowId:
Int
)
:
Int
abstract
def
getDouble
(
rowId:
Int
)
:
Double
abstract
def
getFloat
(
rowId:
Int
)
:
Float
abstract
def
getInt
(
rowId:
Int
)
:
Int
abstract
def
getLong
(
rowId:
Int
)
:
Long
abstract
def
getShort
(
rowId:
Int
)
:
Short
abstract
def
isNullAt
(
rowId:
Int
)
:
Boolean
abstract
def
loadBytes
(
array:
Array
)
:
Unit
abstract
def
nullsNativeAddress
()
:
Long
abstract
def
putArray
(
rowId:
Int
,
offset:
Int
,
length:
Int
)
:
Unit
abstract
def
putBoolean
(
rowId:
Int
,
value:
Boolean
)
:
Unit
abstract
def
putBooleans
(
rowId:
Int
,
count:
Int
,
value:
Boolean
)
:
Unit
abstract
def
putByte
(
rowId:
Int
,
value:
Byte
)
:
Unit
abstract
def
putByteArray
(
rowId:
Int
,
value:
Array
[
Byte
]
,
offset:
Int
,
count:
Int
)
:
Int
abstract
def
putBytes
(
rowId:
Int
,
count:
Int
,
src:
Array
[
Byte
]
,
srcIndex:
Int
)
:
Unit
abstract
def
putBytes
(
rowId:
Int
,
count:
Int
,
value:
Byte
)
:
Unit
abstract
def
putDouble
(
rowId:
Int
,
value:
Double
)
:
Unit
abstract
def
putDoubles
(
rowId:
Int
,
count:
Int
,
src:
Array
[
Byte
]
,
srcIndex:
Int
)
:
Unit
abstract
def
putDoubles
(
rowId:
Int
,
count:
Int
,
src:
Array
[
Double
]
,
srcIndex:
Int
)
:
Unit
abstract
def
putDoubles
(
rowId:
Int
,
count:
Int
,
value:
Double
)
:
Unit
abstract
def
putFloat
(
rowId:
Int
,
value:
Float
)
:
Unit
abstract
def
putFloats
(
rowId:
Int
,
count:
Int
,
src:
Array
[
Byte
]
,
srcIndex:
Int
)
:
Unit
abstract
def
putFloats
(
rowId:
Int
,
count:
Int
,
src:
Array
[
Float
]
,
srcIndex:
Int
)
:
Unit
abstract
def
putFloats
(
rowId:
Int
,
count:
Int
,
value:
Float
)
:
Unit
abstract
def
putInt
(
rowId:
Int
,
value:
Int
)
:
Unit
abstract
def
putInts
(
rowId:
Int
,
count:
Int
,
src:
Array
[
Int
]
,
srcIndex:
Int
)
:
Unit
abstract
def
putInts
(
rowId:
Int
,
count:
Int
,
value:
Int
)
:
Unit
abstract
def
putIntsLittleEndian
(
rowId:
Int
,
count:
Int
,
src:
Array
[
Byte
]
,
srcIndex:
Int
)
:
Unit
abstract
def
putLong
(
rowId:
Int
,
value:
Long
)
:
Unit
abstract
def
putLongs
(
rowId:
Int
,
count:
Int
,
src:
Array
[
Long
]
,
srcIndex:
Int
)
:
Unit
abstract
def
putLongs
(
rowId:
Int
,
count:
Int
,
value:
Long
)
:
Unit
abstract
def
putLongsLittleEndian
(
rowId:
Int
,
count:
Int
,
src:
Array
[
Byte
]
,
srcIndex:
Int
)
:
Unit
abstract
def
putNotNull
(
rowId:
Int
)
:
Unit
abstract
def
putNotNulls
(
rowId:
Int
,
count:
Int
)
:
Unit
abstract
def
putNull
(
rowId:
Int
)
:
Unit
abstract
def
putNulls
(
rowId:
Int
,
count:
Int
)
:
Unit
abstract
def
putShort
(
rowId:
Int
,
value:
Short
)
:
Unit
abstract
def
putShorts
(
rowId:
Int
,
count:
Int
,
src:
Array
[
Short
]
,
srcIndex:
Int
)
:
Unit
abstract
def
putShorts
(
rowId:
Int
,
count:
Int
,
value:
Short
)
:
Unit
abstract
def
reserveInternal
(
capacity:
Int
)
:
Unit
Attributes
protected[
org.apache.spark.sql.execution.vectorized
]
abstract
def
valuesNativeAddress
()
:
Long
Concrete Value Members
final
def
!=
(
arg0:
Any
)
:
Boolean
Definition Classes
AnyRef → Any
final
def
##
()
:
Int
Definition Classes
AnyRef → Any
final
def
==
(
arg0:
Any
)
:
Boolean
Definition Classes
AnyRef → Any
final
def
anyNullsSet
()
:
Boolean
final
def
appendArray
(
length:
Int
)
:
Int
final
def
appendBoolean
(
v:
Boolean
)
:
Int
final
def
appendBooleans
(
count:
Int
,
v:
Boolean
)
:
Int
final
def
appendByte
(
v:
Byte
)
:
Int
final
def
appendByteArray
(
value:
Array
[
Byte
]
,
offset:
Int
,
length:
Int
)
:
Int
final
def
appendBytes
(
length:
Int
,
src:
Array
[
Byte
]
,
offset:
Int
)
:
Int
final
def
appendBytes
(
count:
Int
,
v:
Byte
)
:
Int
final
def
appendDouble
(
v:
Double
)
:
Int
final
def
appendDoubles
(
length:
Int
,
src:
Array
[
Double
]
,
offset:
Int
)
:
Int
final
def
appendDoubles
(
count:
Int
,
v:
Double
)
:
Int
final
def
appendFloat
(
v:
Float
)
:
Int
final
def
appendFloats
(
count:
Int
,
v:
Float
)
:
Int
final
def
appendInt
(
v:
Int
)
:
Int
final
def
appendInts
(
length:
Int
,
src:
Array
[
Int
]
,
offset:
Int
)
:
Int
final
def
appendInts
(
count:
Int
,
v:
Int
)
:
Int
final
def
appendLong
(
v:
Long
)
:
Int
final
def
appendLongs
(
length:
Int
,
src:
Array
[
Long
]
,
offset:
Int
)
:
Int
final
def
appendLongs
(
count:
Int
,
v:
Long
)
:
Int
final
def
appendNotNull
()
:
Int
final
def
appendNotNulls
(
count:
Int
)
:
Int
final
def
appendNull
()
:
Int
final
def
appendNulls
(
count:
Int
)
:
Int
final
def
appendShort
(
v:
Short
)
:
Int
final
def
appendShorts
(
length:
Int
,
src:
Array
[
Short
]
,
offset:
Int
)
:
Int
final
def
appendShorts
(
count:
Int
,
v:
Short
)
:
Int
final
def
appendStruct
(
isNull:
Boolean
)
:
Int
final
def
arrayData
()
:
ColumnVector
final
def
asInstanceOf
[
T0
]
:
T0
Definition Classes
Any
def
clone
()
:
AnyRef
Attributes
protected[
java.lang
]
Definition Classes
AnyRef
Annotations
@throws
(
...
)
final
def
dataType
()
:
DataType
final
def
eq
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
def
equals
(
arg0:
Any
)
:
Boolean
Definition Classes
AnyRef → Any
def
finalize
()
:
Unit
Attributes
protected[
java.lang
]
Definition Classes
AnyRef
Annotations
@throws
(
classOf[java.lang.Throwable]
)
final
def
getArray
(
rowId:
Int
)
:
Array
final
def
getBinary
(
rowId:
Int
)
:
Array
[
Byte
]
final
def
getChildColumn
(
ordinal:
Int
)
:
ColumnVector
final
def
getClass
()
:
Class
[_]
Definition Classes
AnyRef → Any
final
def
getDecimal
(
rowId:
Int
,
precision:
Int
,
scale:
Int
)
:
Decimal
def
getDictionaryIds
()
:
ColumnVector
final
def
getElementsAppended
()
:
Int
def
getMap
(
ordinal:
Int
)
:
MapData
def
getStruct
(
rowId:
Int
,
size:
Int
)
:
ColumnarBatch.Row
def
getStruct
(
rowId:
Int
)
:
ColumnarBatch.Row
final
def
getUTF8String
(
rowId:
Int
)
:
UTF8String
def
hasDictionary
()
:
Boolean
def
hashCode
()
:
Int
Definition Classes
AnyRef → Any
final
def
isArray
()
:
Boolean
final
def
isInstanceOf
[
T0
]
:
Boolean
Definition Classes
Any
final
def
ne
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
final
def
notify
()
:
Unit
Definition Classes
AnyRef
final
def
notifyAll
()
:
Unit
Definition Classes
AnyRef
final
def
numNulls
()
:
Int
final
def
putByteArray
(
rowId:
Int
,
value:
Array
[
Byte
]
)
:
Int
final
def
putDecimal
(
rowId:
Int
,
value:
Decimal
,
precision:
Int
)
:
Unit
def
reserve
(
requiredCapacity:
Int
)
:
Unit
def
reserveDictionaryIds
(
capacity:
Int
)
:
ColumnVector
def
reset
()
:
Unit
def
setDictionary
(
dictionary:
Dictionary
)
:
Unit
final
def
setIsConstant
()
:
Unit
final
def
synchronized
[
T0
]
(
arg0: ⇒
T0
)
:
T0
Definition Classes
AnyRef
def
toString
()
:
String
Definition Classes
AnyRef → Any
final
def
wait
()
:
Unit
Definition Classes
AnyRef
Annotations
@throws
(
...
)
final
def
wait
(
arg0:
Long
,
arg1:
Int
)
:
Unit
Definition Classes
AnyRef
Annotations
@throws
(
...
)
final
def
wait
(
arg0:
Long
)
:
Unit
Definition Classes
AnyRef
Annotations
@throws
(
...
)
Inherited from
AutoCloseable
Inherited from
AnyRef
Inherited from
Any
Ungrouped