org.apache.spark.serializer

Class KryoSerializer

Object

org.apache.spark.serializer.KryoSerializer

All Implemented Interfaces:

java.io.Serializable, Logging, Serializer

public class KryoSerializer
extends Object
implements Serializer, Logging, scala.Serializable

A Spark serializer that uses the Kryo serialization library.

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

Constructor and Description
KryoSerializer(SparkConf conf)

Method Summary

Methods

Modifier and Type	Method and Description
SerializerInstance	newInstance()
com.esotericsoftware.kryo.Kryo	newKryo()
com.esotericsoftware.kryo.io.Output	newKryoOutput()

Methods inherited from class Object

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

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

getSerializer

Methods inherited from interface org.apache.spark.Logging

initialized, initializeIfNecessary, initializeLogging, initLock, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logTrace, logTrace, logWarning, logWarning

Constructor Detail

KryoSerializer

public KryoSerializer(SparkConf conf)

Method Detail

newKryoOutput

public com.esotericsoftware.kryo.io.Output newKryoOutput()

newKryo

public com.esotericsoftware.kryo.Kryo newKryo()

newInstance

public SerializerInstance newInstance()

Specified by:

newInstance in interface Serializer