@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

• Method Summary

  <T> T

  <T> T

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

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

• Field Details

  • INSTANCE

• Method Details

  • serializeStream

    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

    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