Package org.apache.spark.serializer

Class SerializationStream

Object

org.apache.spark.serializer.SerializationStream

All Implemented Interfaces:

Closeable, AutoCloseable

public abstract class SerializationStream
extends Object
implements Closeable

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

Constructor Summary

Constructors

Constructor	Description
SerializationStream()

Method Summary

Modifier and Type	Method	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 java.lang.Object

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

Constructor Details

SerializationStream

public SerializationStream()

Method Details

close

public abstract void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

flush

public abstract void flush()

writeAll

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

writeKey

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

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

writeObject

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

The most general-purpose method to write an object.

writeValue

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

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