Package org.apache.spark.serializer

Class DeserializationStream

Object
org.apache.spark.serializer.DeserializationStream
All Implemented Interfaces:
Closeable, AutoCloseable
public abstract class DeserializationStream extends Object implements Closeable
:: DeveloperApi :: A stream for reading serialized objects.

  • Constructor Summary

    Constructors
    Constructor
    Description
    DeserializationStream()
     

  • Method Summary

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

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

  • Constructor Details

    • DeserializationStream

      public DeserializationStream()

  • Method Details

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

    • close

      public abstract void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable

    • readKey

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

    • readObject

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

    • readValue

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