org.apache.spark.serializer

Class Serializer

Object

org.apache.spark.serializer.Serializer

Direct Known Subclasses:

JavaSerializer, KryoSerializer

public abstract class Serializer
extends Object

:: DeveloperApi :: A serializer. Because some serialization libraries are not thread safe, this class is used to create SerializerInstance objects that do the actual serialization and are guaranteed to only be called from one thread at a time.

Implementations of this trait should implement:

1. a zero-arg constructor or a constructor that accepts a SparkConf as parameter. If both constructors are defined, the latter takes precedence.

2. Java serialization interface.

Note:

Serializers are not required to be wire-compatible across different versions of Spark. They are intended to be used to serialize/de-serialize data within a single Spark application.

Constructor Summary

Constructors

Constructor and Description
Serializer()

Method Summary

Modifier and Type	Method and Description
abstract SerializerInstance	newInstance() Creates a new SerializerInstance.
Serializer	setDefaultClassLoader(ClassLoader classLoader) Sets a class loader for the serializer to use in deserialization.

Methods inherited from class Object

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

Constructor Detail

Serializer

public Serializer()

Method Detail

newInstance

public abstract SerializerInstance newInstance()

Creates a new SerializerInstance.

setDefaultClassLoader

public Serializer setDefaultClassLoader(ClassLoader classLoader)

Sets a class loader for the serializer to use in deserialization.

Parameters:

classLoader - (undocumented)

Returns:

this Serializer object