org.apache.spark.serializer

Class JavaSerializationStream

Object

org.apache.spark.serializer.SerializationStream

org.apache.spark.serializer.JavaSerializationStream

public class JavaSerializationStream
extends SerializationStream

Constructor Summary

Constructors

Constructor and Description
JavaSerializationStream(java.io.OutputStream out, int counterReset)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	flush()
<T> SerializationStream	writeObject(T t, scala.reflect.ClassTag<T> evidence$1) Calling reset to avoid memory leak: http://stackoverflow.com/questions/1281549/memory-leak-traps-in-the-java-standard-api But only call it every 100th time to avoid bloated serialization streams (when the stream 'resets' object class descriptions have to be re-written)

Methods inherited from class org.apache.spark.serializer.SerializationStream

writeAll

Methods inherited from class Object

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

Constructor Detail

JavaSerializationStream

public JavaSerializationStream(java.io.OutputStream out,
                       int counterReset)

Method Detail

writeObject

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

Calling reset to avoid memory leak: http://stackoverflow.com/questions/1281549/memory-leak-traps-in-the-java-standard-api But only call it every 100th time to avoid bloated serialization streams (when the stream 'resets' object class descriptions have to be re-written)

Specified by:

writeObject in class SerializationStream

flush

public void flush()

Specified by:

flush in class SerializationStream

close

public void close()

Specified by:

close in class SerializationStream