org.apache.spark.serializer

Interface SerializerInstance

public interface SerializerInstance

:: DeveloperApi :: An instance of a serializer, for use by one thread at a time.

Method Summary

Methods

Modifier and Type	Method and Description
<T> T	deserialize(java.nio.ByteBuffer bytes, ClassLoader loader, scala.reflect.ClassTag<T> evidence$3)
<T> T	deserialize(java.nio.ByteBuffer bytes, scala.reflect.ClassTag<T> evidence$2)
scala.collection.Iterator<Object>	deserializeMany(java.nio.ByteBuffer buffer)
DeserializationStream	deserializeStream(java.io.InputStream s)
<T> java.nio.ByteBuffer	serialize(T t, scala.reflect.ClassTag<T> evidence$1)
<T> java.nio.ByteBuffer	serializeMany(scala.collection.Iterator<T> iterator, scala.reflect.ClassTag<T> evidence$4)
SerializationStream	serializeStream(java.io.OutputStream s)

Method Detail

serialize

<T> java.nio.ByteBuffer serialize(T t,
                                scala.reflect.ClassTag<T> evidence$1)

deserialize

<T> T deserialize(java.nio.ByteBuffer bytes,
                scala.reflect.ClassTag<T> evidence$2)

deserialize

<T> T deserialize(java.nio.ByteBuffer bytes,
                ClassLoader loader,
                scala.reflect.ClassTag<T> evidence$3)

serializeStream

SerializationStream serializeStream(java.io.OutputStream s)

deserializeStream

DeserializationStream deserializeStream(java.io.InputStream s)

serializeMany

<T> java.nio.ByteBuffer serializeMany(scala.collection.Iterator<T> iterator,
                                    scala.reflect.ClassTag<T> evidence$4)

deserializeMany

scala.collection.Iterator<Object> deserializeMany(java.nio.ByteBuffer buffer)