Spark Chill Example

chill.scala

import java.io.ByteArrayOutputStream
import java.io.ObjectOutputStream
import java.io.Serializable
import com.twitter.chill.{Input, Output, ScalaKryoInstantiator}

class Person extends Serializable {
  var name: String = ""

  def this(name:String) {
    this()
    this.name = name
  }
}

object Person {
  def apply(name: String) = new Person(name)
}

val p0:Person = Person("p0")

val instantiator = new ScalaKryoInstantiator
instantiator.setRegistrationRequired(false)
val kryo = instantiator.newKryo()

val baos:ByteArrayOutputStream = new ByteArrayOutputStream()
val output = new Output(baos)

kryo.writeObject(output, p0)
output.close

val bytes:Array[Byte] = output.toBytes

val deserialized = kryo.readObject(new Input(bytes), classOf[Person])