KeyType - Class of the key
ValueType - Class of the value
StateType - Class of the state data
MappedType - Class of the mapped data
All Implemented Interfaces:
public abstract class
:: Experimental ::
DStream representing the stream of data generated by
operation on a
Additionally, it also gives access to the stream of state snapshots, that is, the state data of
all keys after a batch has updated them.
Methods inherited from class org.apache.spark.streaming.dstream.
DStream cache, checkpoint, compute, context, count, countByValue, countByValueAndWindow, countByWindow, dependencies, filter, flatMap, foreachRDD, foreachRDD, glom, map, mapPartitions, persist, persist, print, print, reduce, reduceByWindow, reduceByWindow, repartition, saveAsObjectFiles, saveAsTextFiles, slice, slice, slideDuration, toPairDStreamFunctions, transform, transform, transformWith, transformWith, union, window, window
Methods inherited from class Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.spark.internal.
Logging initializeLogging, initializeLogIfNecessary, initializeLogIfNecessary, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
DStream<scala.Tuple2< KeyType, StateType>> stateSnapshots()
Return a pair DStream where each RDD is the snapshot of the state of all the keys.