org.apache.spark.sql.execution

Class SparkSqlSerializer

Object

org.apache.spark.serializer.Serializer

org.apache.spark.serializer.KryoSerializer

org.apache.spark.sql.execution.SparkSqlSerializer

All Implemented Interfaces:

java.io.Serializable, Logging

public class SparkSqlSerializer
extends KryoSerializer

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SparkSqlSerializer(SparkConf conf)

Method Summary

Methods

Modifier and Type	Method and Description
static <T> T	deserialize(byte[] bytes, scala.reflect.ClassTag<T> evidence$2)
com.esotericsoftware.kryo.Kryo	newKryo()
static KryoResourcePool	resourcePool()
static <T> byte[]	serialize(T o, scala.reflect.ClassTag<T> evidence$1)

Methods inherited from class org.apache.spark.serializer.KryoSerializer

newInstance, newKryoOutput

Methods inherited from class org.apache.spark.serializer.Serializer

getSerializer, getSerializer, setDefaultClassLoader

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

SparkSqlSerializer

public SparkSqlSerializer(SparkConf conf)

Method Detail

resourcePool

public static KryoResourcePool resourcePool()

serialize

public static <T> byte[] serialize(T o,
                   scala.reflect.ClassTag<T> evidence$1)

deserialize

public static <T> T deserialize(byte[] bytes,
                scala.reflect.ClassTag<T> evidence$2)

newKryo

public com.esotericsoftware.kryo.Kryo newKryo()

Overrides:

newKryo in class KryoSerializer