org.apache.spark.serializer

Class Serializer

java.lang.Object

org.apache.spark.serializer.Serializer

Direct Known Subclasses:

JavaSerializer, KryoSerializer

public abstract class Serializer
extends java.lang.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
protected scala.Option<java.lang.ClassLoader>	defaultClassLoader() Default ClassLoader to use in deserialization.
static Serializer	getSerializer(scala.Option<Serializer> serializer)
static Serializer	getSerializer(Serializer serializer)
abstract SerializerInstance	newInstance() Creates a new SerializerInstance.
Serializer	setDefaultClassLoader(java.lang.ClassLoader classLoader) Sets a class loader for the serializer to use in deserialization.

Methods inherited from class java.lang.Object

clone, equals, finalize, 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)

defaultClassLoader

protected scala.Option<java.lang.ClassLoader> defaultClassLoader()

Default ClassLoader to use in deserialization. Implementations of Serializer should make sure it is using this when set.

Returns:

(undocumented)

setDefaultClassLoader

public Serializer setDefaultClassLoader(java.lang.ClassLoader classLoader)

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

Parameters:

classLoader - (undocumented)

Returns:

this Serializer object

newInstance

public abstract SerializerInstance newInstance()

Creates a new SerializerInstance.