org.apache.spark.serializer

Class SerializerInstance

java.lang.Object

org.apache.spark.serializer.SerializerInstance

Direct Known Subclasses:

DummySerializerInstance

public abstract class SerializerInstance
extends java.lang.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 and Description
SerializerInstance()

Method Summary

Methods

Modifier and Type	Method and Description
abstract <T> T	deserialize(java.nio.ByteBuffer bytes, java.lang.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 java.lang.Object

clone, equals, finalize, 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,
                java.lang.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)