org.apache.paimon.spark

Class SparkInternalRow

java.lang.Object

org.apache.spark.sql.catalyst.InternalRow

org.apache.spark.sql.paimon.shims.InternalRow

org.apache.paimon.spark.SparkInternalRow

All Implemented Interfaces:

Serializable, org.apache.spark.sql.catalyst.expressions.SpecializedGetters

public class SparkInternalRow
extends org.apache.spark.sql.paimon.shims.InternalRow

Spark InternalRow to wrap InternalRow.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SparkInternalRow(RowType rowType)

Method Summary

Modifier and Type	Method and Description
org.apache.spark.sql.catalyst.InternalRow	copy()
boolean	equals(Object o)
static org.apache.spark.unsafe.types.UTF8String	fromPaimon(BinaryString string)
static org.apache.spark.sql.types.Decimal	fromPaimon(Decimal decimal)
static org.apache.spark.sql.catalyst.util.ArrayData	fromPaimon(InternalArray array, ArrayType arrayType)
static org.apache.spark.sql.catalyst.util.MapData	fromPaimon(InternalMap map, DataType mapType)
static org.apache.spark.sql.catalyst.InternalRow	fromPaimon(InternalRow row, RowType rowType)
static Object	fromPaimon(Object o, DataType type)
static long	fromPaimon(Timestamp timestamp)
Object	get(int ordinal, org.apache.spark.sql.types.DataType dataType)
org.apache.spark.sql.catalyst.util.ArrayData	getArray(int ordinal)
byte[]	getBinary(int ordinal)
boolean	getBoolean(int ordinal)
byte	getByte(int ordinal)
org.apache.spark.sql.types.Decimal	getDecimal(int ordinal, int precision, int scale)
double	getDouble(int ordinal)
float	getFloat(int ordinal)
int	getInt(int ordinal)
org.apache.spark.unsafe.types.CalendarInterval	getInterval(int ordinal)
long	getLong(int ordinal)
org.apache.spark.sql.catalyst.util.MapData	getMap(int ordinal)
short	getShort(int ordinal)
org.apache.spark.sql.catalyst.InternalRow	getStruct(int ordinal, int numFields)
org.apache.spark.unsafe.types.UTF8String	getUTF8String(int ordinal)
int	hashCode()
boolean	isNullAt(int ordinal)
int	numFields()
SparkInternalRow	replace(InternalRow row)
void	setNullAt(int i)
void	update(int i, Object value)

Methods inherited from class org.apache.spark.sql.catalyst.InternalRow

anyNull, 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

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SparkInternalRow

public SparkInternalRow(RowType rowType)

Method Detail

replace

public SparkInternalRow replace(InternalRow row)

numFields

public int numFields()

Specified by:

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

setNullAt

public void setNullAt(int i)

Specified by:

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

update

public void update(int i,
                   Object value)

Specified by:

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

copy

public org.apache.spark.sql.catalyst.InternalRow copy()

Specified by:

copy 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 org.apache.spark.sql.types.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)

getInterval

public org.apache.spark.unsafe.types.CalendarInterval getInterval(int ordinal)

getStruct

public org.apache.spark.sql.catalyst.InternalRow getStruct(int ordinal,
                                                           int numFields)

getArray

public org.apache.spark.sql.catalyst.util.ArrayData getArray(int ordinal)

getMap

public org.apache.spark.sql.catalyst.util.MapData getMap(int ordinal)

get

public Object get(int ordinal,
                  org.apache.spark.sql.types.DataType dataType)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

fromPaimon

public static Object fromPaimon(Object o,
                                DataType type)

fromPaimon

public static org.apache.spark.unsafe.types.UTF8String fromPaimon(BinaryString string)

fromPaimon

public static org.apache.spark.sql.types.Decimal fromPaimon(Decimal decimal)

fromPaimon

public static org.apache.spark.sql.catalyst.InternalRow fromPaimon(InternalRow row,
                                                                   RowType rowType)

fromPaimon

public static long fromPaimon(Timestamp timestamp)

fromPaimon

public static org.apache.spark.sql.catalyst.util.ArrayData fromPaimon(InternalArray array,
                                                                      ArrayType arrayType)

fromPaimon

public static org.apache.spark.sql.catalyst.util.MapData fromPaimon(InternalMap map,
                                                                    DataType mapType)