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:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
ColumnarRow(ColumnVector data, int rowId)

Method Summary

Modifier and Type	Method	Description
boolean	anyNull()
org.apache.spark.sql.catalyst.InternalRow	copy()	Revisit this.
Object	get(int ordinal, DataType dataType)
ColumnarArray	getArray(int ordinal)
byte[]	getBinary(int ordinal)
boolean	getBoolean(int ordinal)
byte	getByte(int ordinal)
Decimal	getDecimal(int ordinal, int precision, int scale)
double	getDouble(int ordinal)
float	getFloat(int ordinal)
org.apache.spark.unsafe.types.GeographyVal	getGeography(int ordinal)
org.apache.spark.unsafe.types.GeometryVal	getGeometry(int ordinal)
int	getInt(int ordinal)
CalendarInterval	getInterval(int ordinal)
long	getLong(int ordinal)
ColumnarMap	getMap(int ordinal)
short	getShort(int ordinal)
ColumnarRow	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	numFields()
void	setNullAt(int ordinal)
void	update(int ordinal, Object value)

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

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ColumnarRow

public ColumnarRow(ColumnVector data,
 int rowId)

Method Details

numFields

public int numFields()

Specified by:

numFields in class org.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 class org.apache.spark.sql.catalyst.InternalRow

anyNull

public boolean anyNull()

Overrides:

anyNull in class org.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

public Decimal getDecimal(int ordinal,
 int precision,
 int scale)

getUTF8String

public org.apache.spark.unsafe.types.UTF8String getUTF8String(int ordinal)

getBinary

public byte[] getBinary(int ordinal)

getGeography

public org.apache.spark.unsafe.types.GeographyVal getGeography(int ordinal)

getGeometry

public org.apache.spark.unsafe.types.GeometryVal getGeometry(int ordinal)

getInterval

public CalendarInterval getInterval(int ordinal)

getVariant

public org.apache.spark.unsafe.types.VariantVal getVariant(int ordinal)

getStruct

public ColumnarRow getStruct(int ordinal,
 int numFields)

getArray

public ColumnarArray getArray(int ordinal)

getMap

public ColumnarMap getMap(int ordinal)

get

public Object get(int ordinal,
 DataType dataType)

update

public void update(int ordinal,
 Object value)

Specified by:

update in class org.apache.spark.sql.catalyst.InternalRow

setNullAt

public void setNullAt(int ordinal)

Specified by:

setNullAt in class org.apache.spark.sql.catalyst.InternalRow