org.apache.spark.serializer

Class DeserializationStream

Object

org.apache.spark.serializer.DeserializationStream

Direct Known Subclasses:

JavaDeserializationStream, KryoDeserializationStream

public abstract class DeserializationStream
extends Object

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

Constructor Summary

Constructors

Constructor and Description
DeserializationStream()

Method Summary

Methods

Modifier and Type	Method and Description
scala.collection.Iterator<Object>	asIterator() Read the elements of this stream through an iterator.
abstract void	close()
abstract <T> T	readObject(scala.reflect.ClassTag<T> evidence$6)

Methods inherited from class Object

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

Constructor Detail

DeserializationStream

public DeserializationStream()

Method Detail

readObject

public abstract <T> T readObject(scala.reflect.ClassTag<T> evidence$6)

close

public abstract void close()

asIterator

public scala.collection.Iterator<Object> asIterator()

Read the elements of this stream through an iterator. This can only be called once, as reading each element will consume data from the input source.