org.apache.spark.serializer

Class DummySerializerInstance

Object

org.apache.spark.serializer.SerializerInstance

org.apache.spark.serializer.DummySerializerInstance

@Private
public final class DummySerializerInstance
extends SerializerInstance

Unfortunately, we need a serializer instance in order to construct a DiskBlockObjectWriter. Our shuffle write path doesn't actually use this serializer (since we end up calling the `write() OutputStream methods), but DiskBlockObjectWriter still calls some methods on it. To work around this, we pass a dummy no-op serializer.

Field Summary

Fields

Modifier and Type	Field and Description
static DummySerializerInstance	INSTANCE

Method Summary

Modifier and Type	Method and Description
<T> T	deserialize(java.nio.ByteBuffer bytes, ClassLoader loader, scala.reflect.ClassTag<T> ev1)
<T> T	deserialize(java.nio.ByteBuffer bytes, scala.reflect.ClassTag<T> ev1)
DeserializationStream	deserializeStream(java.io.InputStream s)
<T> java.nio.ByteBuffer	serialize(T t, scala.reflect.ClassTag<T> ev1)
SerializationStream	serializeStream(java.io.OutputStream s)

Methods inherited from class Object

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

Field Detail

INSTANCE

public static final DummySerializerInstance INSTANCE

Method Detail

serializeStream

public SerializationStream serializeStream(java.io.OutputStream s)

Specified by:

serializeStream in class SerializerInstance

serialize

public <T> java.nio.ByteBuffer serialize(T t,
                                         scala.reflect.ClassTag<T> ev1)

Specified by:

serialize in class SerializerInstance

deserializeStream

public DeserializationStream deserializeStream(java.io.InputStream s)

Specified by:

deserializeStream in class SerializerInstance

deserialize

public <T> T deserialize(java.nio.ByteBuffer bytes,
                         ClassLoader loader,
                         scala.reflect.ClassTag<T> ev1)

Specified by:

deserialize in class SerializerInstance

deserialize

public <T> T deserialize(java.nio.ByteBuffer bytes,
                         scala.reflect.ClassTag<T> ev1)

Specified by:

deserialize in class SerializerInstance