public class JavaMapWithStateDStream<KeyType,ValueType,StateType,MappedType> extends JavaDStream<MappedType>
mapWithState
operation on a
JavaPairDStream
. 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.
Modifier and Type | Method and Description |
---|---|
JavaPairDStream<KeyType,StateType> |
stateSnapshots() |
cache, checkpoint, classTag, compute, context, count, countByValue, countByValue, countByValueAndWindow, countByValueAndWindow, countByWindow, dstream, filter, flatMap, flatMapToPair, foreachRDD, foreachRDD, fromDStream, glom, map, mapPartitions, mapPartitionsToPair, mapToPair, persist, persist, print, print, reduce, reduceByWindow, reduceByWindow, repartition, scalaIntToJavaLong, slice, transform, transform, transformToPair, transformToPair, transformWith, transformWith, transformWithToPair, transformWithToPair, union, window, window, wrapRDD
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
checkpoint, context, count, countByValue, countByValue, countByValueAndWindow, countByValueAndWindow, countByWindow, flatMap, flatMapToPair, foreachRDD, foreachRDD, glom, map, mapPartitions, mapPartitionsToPair, mapToPair, print, print, reduce, reduceByWindow, reduceByWindow, scalaIntToJavaLong, slice, transform, transform, transformToPair, transformToPair, transformWith, transformWith, transformWithToPair, transformWithToPair
public JavaPairDStream<KeyType,StateType> stateSnapshots()