org.apache.spark.serializer

Class JavaSerializer

java.lang.Object

org.apache.spark.serializer.Serializer

org.apache.spark.serializer.JavaSerializer

All Implemented Interfaces:

java.io.Externalizable, java.io.Serializable

public class JavaSerializer
extends Serializer
implements java.io.Externalizable

:: DeveloperApi :: A Spark serializer that uses Java's built-in serialization.

Note that this serializer is not guaranteed to be wire-compatible across different versions of Spark. It is intended to be used to serialize/de-serialize data within a single Spark application.

See Also:

Serialized Form

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JavaSerializer()
	JavaSerializer(SparkConf conf)

Method Summary

Methods

Modifier and Type	Method and Description
SerializerInstance	newInstance() Creates a new SerializerInstance.
void	readExternal(java.io.ObjectInput in)
void	writeExternal(java.io.ObjectOutput out)

Methods inherited from class org.apache.spark.serializer.Serializer

defaultClassLoader, getSerializer, getSerializer, setDefaultClassLoader

Methods inherited from class java.lang.Object

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

Constructor Detail

JavaSerializer

public JavaSerializer(SparkConf conf)

JavaSerializer

protected JavaSerializer()

Method Detail

newInstance

public SerializerInstance newInstance()

Description copied from class: Serializer

Creates a new SerializerInstance.

Specified by:

newInstance in class Serializer

writeExternal

public void writeExternal(java.io.ObjectOutput out)

Specified by:

writeExternal in interface java.io.Externalizable

readExternal

public void readExternal(java.io.ObjectInput in)

Specified by:

readExternal in interface java.io.Externalizable