public class KryoSerializer extends Serializer implements Logging, java.io.Serializable
Constructor and Description |
---|
KryoSerializer(SparkConf conf) |
Modifier and Type | Method and Description |
---|---|
int |
maxBufferSizeMb() |
SerializerInstance |
newInstance()
Creates a new
SerializerInstance . |
com.esotericsoftware.kryo.Kryo |
newKryo() |
com.esotericsoftware.kryo.io.Output |
newKryoOutput() |
setDefaultClassLoader
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
initializeLogging, initializeLogIfNecessary, initializeLogIfNecessary, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public KryoSerializer(SparkConf conf)
public int maxBufferSizeMb()
public com.esotericsoftware.kryo.io.Output newKryoOutput()
public com.esotericsoftware.kryo.Kryo newKryo()
public SerializerInstance newInstance()
Serializer
SerializerInstance
.newInstance
in class Serializer