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 that 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

Methods

Modifier and Type	Method and Description
static Serializer	getSerializer(scala.Option<Serializer> serializer)
static Serializer	getSerializer(Serializer serializer)
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

getSerializer

public static Serializer getSerializer(Serializer serializer)

getSerializer

public static Serializer getSerializer(scala.Option<Serializer> serializer)

setDefaultClassLoader

public Serializer setDefaultClassLoader(ClassLoader classLoader)

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

Returns:

this Serializer object

newInstance

public abstract SerializerInstance newInstance()

Creates a new SerializerInstance.