public class JavaSerializer extends Object implements Serializer, java.io.Externalizable
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.
Constructor and Description |
---|
JavaSerializer(SparkConf conf) |
Modifier and Type | Method and Description |
---|---|
SerializerInstance |
newInstance() |
void |
readExternal(java.io.ObjectInput in) |
void |
writeExternal(java.io.ObjectOutput out) |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getSerializer
public JavaSerializer(SparkConf conf)
public SerializerInstance newInstance()
newInstance
in interface Serializer
public void writeExternal(java.io.ObjectOutput out)
writeExternal
in interface java.io.Externalizable
public void readExternal(java.io.ObjectInput in)
readExternal
in interface java.io.Externalizable