org.apache.spark.sql.api.java

Class JavaToScalaUDTWrapper<UserType>

Object

org.apache.spark.sql.catalyst.types.DataType

org.apache.spark.sql.catalyst.types.UserDefinedType<UserType>

org.apache.spark.sql.api.java.JavaToScalaUDTWrapper<UserType>

All Implemented Interfaces:

java.io.Serializable

public class JavaToScalaUDTWrapper<UserType>
extends org.apache.spark.sql.catalyst.types.UserDefinedType<UserType>
implements scala.Serializable

Scala wrapper for a Java UserDefinedType

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.spark.sql.catalyst.types.DataType

org.apache.spark.sql.catalyst.types.DataType.CaseClassStringParser$, org.apache.spark.sql.catalyst.types.DataType.JSortedObject$

Constructor Summary

Constructors

Constructor and Description
JavaToScalaUDTWrapper(UserDefinedType<UserType> javaUDT)

Method Summary

Methods

Modifier and Type	Method and Description
UserType	deserialize(Object datum) Convert a SQL datum to the user type
UserDefinedType<UserType>	javaUDT()
Object	serialize(Object obj) Convert the user type to a SQL datum
org.apache.spark.sql.catalyst.types.DataType	sqlType() Underlying storage type for this UDT
Class<UserType>	userClass()

Methods inherited from class org.apache.spark.sql.catalyst.types.UserDefinedType

jsonValue, pyUDT

Methods inherited from class org.apache.spark.sql.catalyst.types.DataType

equalsIgnoreNullability, fromCaseClassString, fromJson, isPrimitive, json, prettyJson, typeName, unapply

Methods inherited from class Object

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

Constructor Detail

JavaToScalaUDTWrapper

public JavaToScalaUDTWrapper(UserDefinedType<UserType> javaUDT)

Method Detail

javaUDT

public UserDefinedType<UserType> javaUDT()

sqlType

public org.apache.spark.sql.catalyst.types.DataType sqlType()

Underlying storage type for this UDT

Specified by:

sqlType in class org.apache.spark.sql.catalyst.types.UserDefinedType<UserType>

serialize

public Object serialize(Object obj)

Convert the user type to a SQL datum

Specified by:

serialize in class org.apache.spark.sql.catalyst.types.UserDefinedType<UserType>

deserialize

public UserType deserialize(Object datum)

Convert a SQL datum to the user type

Specified by:

deserialize in class org.apache.spark.sql.catalyst.types.UserDefinedType<UserType>

userClass

public Class<UserType> userClass()

Specified by:

userClass in class org.apache.spark.sql.catalyst.types.UserDefinedType<UserType>