Packages

c

org.apache.spark.serializer

KryoSerializer

class KryoSerializer extends Serializer with Logging with Serializable

A Spark serializer that uses the Kryo serialization library.

Source
KryoSerializer.scala
Note

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.

Linear Supertypes
Serializable, Logging, Serializer, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. KryoSerializer
  2. Serializable
  3. Logging
  4. Serializer
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new KryoSerializer(conf: SparkConf)

Value Members

  1. val maxBufferSizeMb: Int
  2. def newInstance(): SerializerInstance

    Creates a new SerializerInstance.

    Creates a new SerializerInstance.

    Definition Classes
    KryoSerializerSerializer
  3. def newKryo(): Kryo
  4. def newKryoOutput(): Output
  5. def pool: KryoPool
  6. def setDefaultClassLoader(classLoader: ClassLoader): Serializer

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

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

    returns

    this Serializer object

    Definition Classes
    KryoSerializerSerializer