Package org.apache.iceberg.spark

Class SparkValueConverter

java.lang.Object

org.apache.iceberg.spark.SparkValueConverter

public class SparkValueConverter
extends Object

A utility class that converts Spark values to Iceberg's internal representation.

Method Summary

Modifier and Type	Method	Description
static Record	convert(Schema schema, org.apache.spark.sql.Row row)
static Object	convert(Type type, Object object)
static Object	convertToSpark(Type type, Object object)

Methods inherited from class java.lang.Object

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

Method Details

convert

public static Record convert(Schema schema,
 org.apache.spark.sql.Row row)

convert

public static Object convert(Type type,
 Object object)

convertToSpark

public static Object convertToSpark(Type type,
 Object object)