org.apache.spark.serializer

Class DeserializationStream

Object

org.apache.spark.serializer.DeserializationStream

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.
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)