- By Inheritance
- Hide All
- Show All
ConstantInputDStream[T] extends InputDStream[T]
An input stream that always returns the same RDD on each time step.
DStream[T] extends Serializable with Logging
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] extends DStream[T]
This is the abstract base class for all input streams.
MapWithStateDStream[KeyType, ValueType, StateType, MappedType] extends DStream[MappedType]
DStream representing the stream of data generated by
mapWithStateoperation on a pair DStream.
Class of the key
Class of the value
Class of the state data
Class of the mapped data
PairDStreamFunctions[K, V] extends Serializable
Extra functions available on DStream of (key, value) pairs through an implicit conversion.
ReceiverInputDStream[T] extends InputDStream[T]
Abstract class for defining any org.apache.spark.streaming.dstream.InputDStream that has to start a receiver on worker nodes to receive external data.
Class type of the object of this stream
- object DStream extends Serializable