Developer API

org.apache.spark.serializer

Class SerializerInstance

Object

org.apache.spark.serializer.SerializerInstance

Direct Known Subclasses:

DummySerializerInstance

public abstract class SerializerInstance
extends Object

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

Constructor and Description
SerializerInstance()

Method Summary

Modifier and Type	Method and Description
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)