Package org.apache.spark.serializer

Class SerializerHelper

Object

org.apache.spark.serializer.SerializerHelper

public class SerializerHelper
extends Object

Constructor Summary

Constructors

Constructor	Description
SerializerHelper()

Method Summary

Modifier and Type	Method	Description
static <T> T	deserializeFromChunkedBuffer(SerializerInstance serializerInstance, org.apache.spark.util.io.ChunkedByteBuffer bytes, scala.reflect.ClassTag<T> evidence$2)
static org.slf4j.Logger	org$apache$spark$internal$Logging$$log_()
static void	org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)
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 java.lang.Object

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

Constructor Details

SerializerHelper

public SerializerHelper()

Method Details

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)