Package org.apache.spark.streaming.dstream

Various implementations of DStreams.

See:
Description

Class Summary

ConstantInputDStream<T>	An input stream that always returns the same RDD on each timestep.
DStream<T>	A Discretized Stream (DStream), the basic abstraction in Spark Streaming, is a continuous sequence of RDDs (of the same type) representing a continuous stream of data (see org.apache.spark.rdd.RDD in the Spark core documentation for more details on RDDs).
InputDStream<T>	This is the abstract base class for all input streams.
PairDStreamFunctions<K,V>	Extra functions available on DStream of (key, value) pairs through an implicit conversion.
ReceiverInputDStream<T>	Abstract class for defining any InputDStream that has to start a receiver on worker nodes to receive external data.

Package org.apache.spark.streaming.dstream Description

Various implementations of DStreams.