Package org.apache.spark.serializer

Class SerializerInstance

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

Constructor	Description
SerializerInstance()

Method Summary

Modifier and Type	Method	Description
abstract <T> T	deserialize(ByteBuffer bytes, ClassLoader loader, scala.reflect.ClassTag<T> evidence$3)
abstract <T> T	deserialize(ByteBuffer bytes, scala.reflect.ClassTag<T> evidence$2)
abstract DeserializationStream	deserializeStream(InputStream s)
abstract <T> ByteBuffer	serialize(T t, scala.reflect.ClassTag<T> evidence$1)
abstract SerializationStream	serializeStream(OutputStream s)

Methods inherited from class java.lang.Object

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

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

public abstract DeserializationStream deserializeStream(InputStream s)

serialize

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

serializeStream

public abstract SerializationStream serializeStream(OutputStream s)