org.apache.spark.serializer

Class SerializerHelper

Object

org.apache.spark.serializer.SerializerHelper

public class SerializerHelper
extends Object

Constructor Summary

Constructors

Constructor and Description
SerializerHelper()

Method Summary

Modifier and Type	Method and Description
static <T> T	deserializeFromChunkedBuffer(SerializerInstance serializerInstance, org.apache.spark.util.io.ChunkedByteBuffer bytes, scala.reflect.ClassTag<T> evidence$2)
static void	org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)
static org.slf4j.Logger	org$apache$spark$internal$Logging$$log_()
static <T> org.apache.spark.util.io.ChunkedByteBuffer	serializeToChunkedBuffer(SerializerInstance serializerInstance, T objectToSerialize, long estimatedSize, scala.reflect.ClassTag<T> evidence$1)

Methods inherited from class Object

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

Constructor Detail

SerializerHelper

public SerializerHelper()

Method Detail

serializeToChunkedBuffer

public static <T> org.apache.spark.util.io.ChunkedByteBuffer serializeToChunkedBuffer(SerializerInstance serializerInstance,
                                                                                      T objectToSerialize,
                                                                                      long estimatedSize,
                                                                                      scala.reflect.ClassTag<T> evidence$1)

Parameters:

serializerInstance - instance of SerializerInstance

objectToSerialize - the object to serialize, of type T

estimatedSize - estimated size of t, used as a hint to choose proper chunk size

evidence$1 - (undocumented)

Returns:

(undocumented)

deserializeFromChunkedBuffer

public static <T> T deserializeFromChunkedBuffer(SerializerInstance serializerInstance,
                                                 org.apache.spark.util.io.ChunkedByteBuffer bytes,
                                                 scala.reflect.ClassTag<T> evidence$2)

org$apache$spark$internal$Logging$$log_

public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()

org$apache$spark$internal$Logging$$log__$eq

public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)