Skip to content

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¶