SerializerInstance¶

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

Contract¶

deserialize¶

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

deserializeStream¶

deserializeStream(
  s: InputStream): DeserializationStream

serialize¶

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

serializeStream¶

serializeStream(
  s: OutputStream): SerializationStream

Implementations¶

• JavaSerializerInstance
• KryoSerializerInstance
• UnsafeRowSerializerInstance (Spark SQL)