Object

org.apache.spark.serializer.SerializerInstance

Direct Known Subclasses:
DummySerializerInstance

public abstract class SerializerInstance extends Object

:: DeveloperApi :: An instance of a serializer, for use by one thread at a time.

It is legal to create multiple serialization / deserialization streams from the same SerializerInstance as long as those streams are all used within the same thread.

  • Constructor Summary

    Constructors

  • Method Summary

    abstract <T> T

    abstract <T> T

    deserialize(ByteBuffer bytes, scala.reflect.ClassTag<T> evidence$2)

    serialize(T t, scala.reflect.ClassTag<T> evidence$1)

  • Constructor Details

    • SerializerInstance

      public SerializerInstance()

  • Method Details

    • deserialize

      public abstract <T> T deserialize(ByteBuffer bytes, scala.reflect.ClassTag<T> evidence$2)

    • deserialize

      public abstract <T> T deserialize(ByteBuffer bytes, ClassLoader loader, scala.reflect.ClassTag<T> evidence$3)

    • deserializeStream

    • serialize

      public abstract <T> ByteBuffer serialize(T t, scala.reflect.ClassTag<T> evidence$1)

    • serializeStream