org.apache.spark.serializer
Class SerializerInstance

Object
  org.apache.spark.serializer.SerializerInstance

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

SerializerInstance()

Method Summary

abstract <T> T	deserialize(java.nio.ByteBuffer bytes, ClassLoader loader, scala.reflect.ClassTag<T> evidence$3)
abstract <T> T	deserialize(java.nio.ByteBuffer bytes, scala.reflect.ClassTag<T> evidence$2)
abstract DeserializationStream	deserializeStream(java.io.InputStream s)
abstract <T> java.nio.ByteBuffer	serialize(T t, scala.reflect.ClassTag<T> evidence$1)
abstract SerializationStream	serializeStream(java.io.OutputStream s)

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SerializerInstance

public SerializerInstance()

Method Detail

serialize

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

deserialize

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

deserialize

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

serializeStream

public abstract SerializationStream serializeStream(java.io.OutputStream s)

deserializeStream

public abstract DeserializationStream deserializeStream(java.io.InputStream s)