org.apache.spark.serializer

Class SerializationStream

Object

org.apache.spark.serializer.SerializationStream

All Implemented Interfaces:

java.io.Closeable, AutoCloseable

public abstract class SerializationStream
extends Object
implements java.io.Closeable

:: DeveloperApi :: A stream for writing serialized objects.

Constructor Summary

Constructors

Constructor and Description
SerializationStream()

Method Summary

Modifier and Type	Method and Description
abstract void	close()
abstract void	flush()
<T> SerializationStream	writeAll(scala.collection.Iterator<T> iter, scala.reflect.ClassTag<T> evidence$7)
<T> SerializationStream	writeKey(T key, scala.reflect.ClassTag<T> evidence$5) Writes the object representing the key of a key-value pair.
abstract <T> SerializationStream	writeObject(T t, scala.reflect.ClassTag<T> evidence$4) The most general-purpose method to write an object.
<T> SerializationStream	writeValue(T value, scala.reflect.ClassTag<T> evidence$6) Writes the object representing the value of a key-value pair.

Methods inherited from class Object

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

Constructor Detail

SerializationStream

public SerializationStream()

Method Detail

writeObject

public abstract <T> SerializationStream writeObject(T t,
                                                    scala.reflect.ClassTag<T> evidence$4)

The most general-purpose method to write an object.

writeKey

public <T> SerializationStream writeKey(T key,
                                        scala.reflect.ClassTag<T> evidence$5)

Writes the object representing the key of a key-value pair.

writeValue

public <T> SerializationStream writeValue(T value,
                                          scala.reflect.ClassTag<T> evidence$6)

Writes the object representing the value of a key-value pair.

flush

public abstract void flush()

close

public abstract void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface AutoCloseable

writeAll

public <T> SerializationStream writeAll(scala.collection.Iterator<T> iter,
                                        scala.reflect.ClassTag<T> evidence$7)