org.apache.paimon.spark

Class DataConverter

java.lang.Object

org.apache.paimon.spark.DataConverter

public class DataConverter
extends Object

A data converter that convert Paimon data to Spark Data.

Constructor Summary

Constructors

Constructor and Description
DataConverter()

Method Summary

Modifier and Type	Method and Description
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)

Methods inherited from class java.lang.Object

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

Constructor Detail

DataConverter

public DataConverter()

Method Detail

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)