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

Back to top