Package 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	Description
static final DummySerializerInstance	INSTANCE

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

INSTANCE

public static final DummySerializerInstance INSTANCE

Method Details

serializeStream

public SerializationStream serializeStream(OutputStream s)

Specified by:

serializeStream in class SerializerInstance

serialize

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

Specified by:

serialize in class SerializerInstance

deserializeStream

public DeserializationStream deserializeStream(InputStream s)

Specified by:

deserializeStream in class SerializerInstance

deserialize

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

Specified by:

deserialize in class SerializerInstance

deserialize

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

Specified by:

deserialize in class SerializerInstance