SerializerInstance¶

SerializerInstance is an abstraction of serializer instances (for use by one thread at a time).

Contract¶

Deserializing (from ByteBuffer)¶

deserialize[T: ClassTag](
  bytes: ByteBuffer): T
deserialize[T: ClassTag](
  bytes: ByteBuffer,
  loader: ClassLoader): T

Used when:

• TaskRunner is requested to run
• ResultTask is requested to run
• ShuffleMapTask is requested to run
• TaskResultGetter is requested to enqueueFailedTask
• others

Deserializing (from InputStream)¶

deserializeStream(
  s: InputStream): DeserializationStream

Serializing (to ByteBuffer)¶

serialize[T: ClassTag](
  t: T): ByteBuffer

Serializing (to OutputStream)¶

serializeStream(
  s: OutputStream): SerializationStream

Implementations¶

• JavaSerializerInstance
• KryoSerializerInstance
• UnsafeRowSerializerInstance (Spark SQL)