|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |
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. |
Various implementations of DStreams.
|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |