org.apache.spark.serializer
Class DeserializationStream

Object
  extended by org.apache.spark.serializer.DeserializationStream

public abstract class DeserializationStream
extends Object

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


Constructor Summary
DeserializationStream()
           
 
Method Summary
 scala.collection.Iterator<Object> asIterator()
          Read the elements of this stream through an iterator.
 scala.collection.Iterator<scala.Tuple2<Object,Object>> asKeyValueIterator()
          Read the elements of this stream through an iterator over key-value pairs.
abstract  void close()
           
<T> T
readKey(scala.reflect.ClassTag<T> evidence$9)
          Reads the object representing the key of a key-value pair.
abstract
<T> T
readObject(scala.reflect.ClassTag<T> evidence$8)
          The most general-purpose method to read an object.
<T> T
readValue(scala.reflect.ClassTag<T> evidence$10)
          Reads 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

DeserializationStream

public DeserializationStream()
Method Detail

readObject

public abstract <T> T readObject(scala.reflect.ClassTag<T> evidence$8)
The most general-purpose method to read an object.


readKey

public <T> T readKey(scala.reflect.ClassTag<T> evidence$9)
Reads the object representing the key of a key-value pair.


readValue

public <T> T readValue(scala.reflect.ClassTag<T> evidence$10)
Reads the object representing the value of a key-value pair.


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.

Returns:
(undocumented)

asKeyValueIterator

public scala.collection.Iterator<scala.Tuple2<Object,Object>> asKeyValueIterator()
Read the elements of this stream through an iterator over key-value pairs. This can only be called once, as reading each element will consume data from the input source.

Returns:
(undocumented)