|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
Object org.apache.spark.serializer.Serializer
public abstract class Serializer
:: 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 | |
---|---|
Serializer()
|
Method Summary | |
---|---|
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 |
---|
public Serializer()
Method Detail |
---|
public static Serializer getSerializer(Serializer serializer)
public static Serializer getSerializer(scala.Option<Serializer> serializer)
public Serializer setDefaultClassLoader(ClassLoader classLoader)
classLoader
- (undocumented)
public abstract SerializerInstance newInstance()
SerializerInstance
.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |