Package org.apache.spark.sql.vectorized
Class ColumnarRow
Object
org.apache.spark.sql.catalyst.InternalRow
org.apache.spark.sql.vectorized.ColumnarRow
- All Implemented Interfaces:
Serializable
,org.apache.spark.sql.catalyst.expressions.SpecializedGetters
@Evolving
public final class ColumnarRow
extends org.apache.spark.sql.catalyst.InternalRow
Row abstraction in
ColumnVector
.- See Also:
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionboolean
anyNull()
org.apache.spark.sql.catalyst.InternalRow
copy()
Revisit this.getArray
(int ordinal) byte[]
getBinary
(int ordinal) boolean
getBoolean
(int ordinal) byte
getByte
(int ordinal) getDecimal
(int ordinal, int precision, int scale) double
getDouble
(int ordinal) float
getFloat
(int ordinal) int
getInt
(int ordinal) getInterval
(int ordinal) long
getLong
(int ordinal) getMap
(int ordinal) short
getShort
(int ordinal) getStruct
(int ordinal, int numFields) org.apache.spark.unsafe.types.UTF8String
getUTF8String
(int ordinal) org.apache.spark.unsafe.types.VariantVal
getVariant
(int ordinal) boolean
isNullAt
(int ordinal) int
void
setNullAt
(int ordinal) void
Methods inherited from class org.apache.spark.sql.catalyst.InternalRow
apply, copyValue, empty, fromSeq, getAccessor, getAccessor$default$2, getString, getWriter, setBoolean, setByte, setDecimal, setDouble, setFloat, setInt, setInterval, setLong, setShort, toSeq, toSeq
-
Constructor Details
-
ColumnarRow
-
-
Method Details
-
numFields
public int numFields()- Specified by:
numFields
in classorg.apache.spark.sql.catalyst.InternalRow
-
copy
public org.apache.spark.sql.catalyst.InternalRow copy()Revisit this. This is expensive. This is currently only used in test paths.- Specified by:
copy
in classorg.apache.spark.sql.catalyst.InternalRow
-
anyNull
public boolean anyNull()- Overrides:
anyNull
in classorg.apache.spark.sql.catalyst.InternalRow
-
isNullAt
public boolean isNullAt(int ordinal) -
getBoolean
public boolean getBoolean(int ordinal) -
getByte
public byte getByte(int ordinal) -
getShort
public short getShort(int ordinal) -
getInt
public int getInt(int ordinal) -
getLong
public long getLong(int ordinal) -
getFloat
public float getFloat(int ordinal) -
getDouble
public double getDouble(int ordinal) -
getDecimal
-
getUTF8String
public org.apache.spark.unsafe.types.UTF8String getUTF8String(int ordinal) -
getBinary
public byte[] getBinary(int ordinal) -
getInterval
-
getVariant
public org.apache.spark.unsafe.types.VariantVal getVariant(int ordinal) -
getStruct
-
getArray
-
getMap
-
get
-
update
- Specified by:
update
in classorg.apache.spark.sql.catalyst.InternalRow
-
setNullAt
public void setNullAt(int ordinal) - Specified by:
setNullAt
in classorg.apache.spark.sql.catalyst.InternalRow
-