Skip to content

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


Last update: 2021-07-22
Back to top