Hierarchy For Package org.apache.spark.streaming.dstream

Package Hierarchies:

• All Packages

Class Hierarchy

• Object
  • org.apache.spark.streaming.dstream.DStream<T> (implements org.apache.spark.Logging, scala.Serializable)
    • org.apache.spark.streaming.dstream.FilteredDStream<T>
    • org.apache.spark.streaming.dstream.FlatMappedDStream<T,U>
    • org.apache.spark.streaming.dstream.FlatMapValuedDStream<K,V,U>
    • org.apache.spark.streaming.dstream.ForEachDStream<T>
    • org.apache.spark.streaming.dstream.GlommedDStream<T>
    • org.apache.spark.streaming.dstream.InputDStream<T>
      • org.apache.spark.streaming.dstream.ConstantInputDStream<T>
      • org.apache.spark.streaming.dstream.FileInputDStream<K,V,F>
      • org.apache.spark.streaming.dstream.QueueInputDStream<T>
      • org.apache.spark.streaming.dstream.ReceiverInputDStream<T>
        • org.apache.spark.streaming.dstream.PluggableInputDStream<T>
        • org.apache.spark.streaming.dstream.RawInputDStream<T> (implements org.apache.spark.Logging)
        • org.apache.spark.streaming.dstream.SocketInputDStream<T>
    • org.apache.spark.streaming.dstream.MapPartitionedDStream<T,U>
    • org.apache.spark.streaming.dstream.MappedDStream<T,U>
    • org.apache.spark.streaming.dstream.MapValuedDStream<K,V,U>
    • org.apache.spark.streaming.dstream.ReducedWindowedDStream<K,V>
    • org.apache.spark.streaming.dstream.ShuffledDStream<K,V,C>
    • org.apache.spark.streaming.dstream.StateDStream<K,V,S>
    • org.apache.spark.streaming.dstream.TransformedDStream<U>
    • org.apache.spark.streaming.dstream.UnionDStream<T>
    • org.apache.spark.streaming.dstream.WindowedDStream<T>
  • org.apache.spark.streaming.dstream.DStreamCheckpointData<T> (implements org.apache.spark.Logging, scala.Serializable)
    • org.apache.spark.streaming.dstream.FileInputDStream.FileInputDStreamCheckpointData
  • org.apache.spark.streaming.dstream.PairDStreamFunctions<K,V> (implements scala.Serializable)
  • org.apache.spark.streaming.receiver.Receiver<T> (implements scala.Serializable)
    • org.apache.spark.streaming.dstream.RawNetworkReceiver (implements org.apache.spark.Logging)
    • org.apache.spark.streaming.dstream.SocketReceiver<T> (implements org.apache.spark.Logging)