org.apache.spark.sql.test

Class ExamplePointUDT

Object

org.apache.spark.sql.types.DataType

org.apache.spark.sql.types.UserDefinedType<ExamplePoint>

org.apache.spark.sql.test.ExamplePointUDT

All Implemented Interfaces:

java.io.Serializable

public class ExamplePointUDT
extends UserDefinedType<ExamplePoint>

User-defined type for ExamplePoint.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ExamplePointUDT()

Method Summary

Methods

Modifier and Type	Method and Description
ExamplePointUDT	asNullable() For UDT, asNullable will not change the nullability of its internal sqlType and just returns itself.
ExamplePoint	deserialize(Object datum) Convert a SQL datum to the user type
String	pyUDT() Paired Python UDT class, if exists.
scala.collection.Seq<Object>	serialize(Object obj) Convert the user type to a SQL datum
DataType	sqlType() Underlying storage type for this UDT
Class<ExamplePoint>	userClass() Class object for the UserType

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

defaultSize, jsonValue

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

equalsIgnoreCompatibleNullability, equalsIgnoreNullability, fromCaseClassString, fromJson, isPrimitive, json, prettyJson, sameType, simpleString, typeName, unapply

Methods inherited from class Object

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

Constructor Detail

ExamplePointUDT

public ExamplePointUDT()

Method Detail

sqlType

public DataType sqlType()

Description copied from class: UserDefinedType

Underlying storage type for this UDT

Specified by:

sqlType in class UserDefinedType<ExamplePoint>

pyUDT

public String pyUDT()

Description copied from class: UserDefinedType

Paired Python UDT class, if exists.

Overrides:

pyUDT in class UserDefinedType<ExamplePoint>

serialize

public scala.collection.Seq<Object> serialize(Object obj)

Description copied from class: UserDefinedType

Convert the user type to a SQL datum

TODO: Can we make this take obj: UserType? The issue is in ScalaReflection.convertToCatalyst, where we need to convert Any to UserType.

Specified by:

serialize in class UserDefinedType<ExamplePoint>

deserialize

public ExamplePoint deserialize(Object datum)

Description copied from class: UserDefinedType

Convert a SQL datum to the user type

Specified by:

deserialize in class UserDefinedType<ExamplePoint>

userClass

public Class<ExamplePoint> userClass()

Description copied from class: UserDefinedType

Class object for the UserType

Specified by:

userClass in class UserDefinedType<ExamplePoint>

asNullable

public ExamplePointUDT asNullable()

Description copied from class: UserDefinedType

For UDT, asNullable will not change the nullability of its internal sqlType and just returns itself.

Overrides:

asNullable in class UserDefinedType<ExamplePoint>