TileUDT.scala

package org.apache.spark.sql.gt

import ...

class TileUDT extends UserDefinedType[Tile] {

  override val typeName = "st_tile"

  override def userClass = classOf[Tile]

  override def sqlType = StructType(Seq(StructField(typeName + "_kryo", BinaryType)))

  override def serialize(obj: Tile) =
    Option(obj).map(t ⇒ KryoSerializer.serialize(t)).map(k ⇒ InternalRow(k)).orNull

  override def deserialize(datum: Any) = {
    val row = datum.asInstanceOf[InternalRow]
    Option(row).flatMap(row ⇒ Option(row.getBinary(0))).map(b ⇒ KryoSerializer.deserialize(b)).orNull
  }
}

package org.apache.spark.sql.gt

import ...

class TileUDT extends UserDefinedType[Tile] {

  override val typeName = "st_tile"

  override def userClass = classOf[Tile]

  override def sqlType = StructType(Seq(StructField(typeName + "_kryo", BinaryType)))

  override def serialize(obj: Tile) =
    Option(obj).map(t ⇒ KryoSerializer.serialize(t)).map(k ⇒ InternalRow(k)).orNull

  override def deserialize(datum: Any) = {
    val row = datum.asInstanceOf[InternalRow]
    Option(row).flatMap(row ⇒ Option(row.getBinary(0))).map(b ⇒ KryoSerializer.deserialize(b)).orNull
  }
}