public class KryoSerializer extends Serializer implements java.io.Serializable
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.
Constructor and Description |
---|
KryoSerializer(SparkConf conf) |
Modifier and Type | Method and Description |
---|---|
protected static void |
defaultClassLoader_$eq(scala.Option<java.lang.ClassLoader> x$1) |
protected static scala.Option<java.lang.ClassLoader> |
defaultClassLoader() |
protected static void |
initializeLogIfNecessary(boolean isInterpreter) |
protected static boolean |
isTraceEnabled() |
protected static org.slf4j.Logger |
log() |
protected static void |
logDebug(scala.Function0<java.lang.String> msg) |
protected static void |
logDebug(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
protected static void |
logError(scala.Function0<java.lang.String> msg) |
protected static void |
logError(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
protected static void |
logInfo(scala.Function0<java.lang.String> msg) |
protected static void |
logInfo(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
protected static java.lang.String |
logName() |
protected static void |
logTrace(scala.Function0<java.lang.String> msg) |
protected static void |
logTrace(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
protected static void |
logWarning(scala.Function0<java.lang.String> msg) |
protected static void |
logWarning(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
int |
maxBufferSizeMb() |
SerializerInstance |
newInstance()
Creates a new
SerializerInstance . |
com.esotericsoftware.kryo.Kryo |
newKryo() |
com.esotericsoftware.kryo.io.Output |
newKryoOutput() |
static Serializer |
setDefaultClassLoader(java.lang.ClassLoader classLoader) |
defaultClassLoader, setDefaultClassLoader
public KryoSerializer(SparkConf conf)
protected static scala.Option<java.lang.ClassLoader> defaultClassLoader()
protected static void defaultClassLoader_$eq(scala.Option<java.lang.ClassLoader> x$1)
public static Serializer setDefaultClassLoader(java.lang.ClassLoader classLoader)
protected static java.lang.String logName()
protected static org.slf4j.Logger log()
protected static void logInfo(scala.Function0<java.lang.String> msg)
protected static void logDebug(scala.Function0<java.lang.String> msg)
protected static void logTrace(scala.Function0<java.lang.String> msg)
protected static void logWarning(scala.Function0<java.lang.String> msg)
protected static void logError(scala.Function0<java.lang.String> msg)
protected static void logInfo(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void logDebug(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void logTrace(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void logWarning(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void logError(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static boolean isTraceEnabled()
protected static void initializeLogIfNecessary(boolean isInterpreter)
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