Class JavaMapWithStateDStream<KeyType,ValueType,StateType,MappedType>

Type Parameters:
KeyType - Class of the keys
ValueType - Class of the values
StateType - Class of the state data
MappedType - Class of the mapped data
All Implemented Interfaces:
Serializable, JavaDStreamLike<MappedType,JavaDStream<MappedType>,JavaRDD<MappedType>>, scala.Serializable

public class JavaMapWithStateDStream<KeyType,ValueType,StateType,MappedType> extends JavaDStream<MappedType>
DStream representing the stream of data generated by 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.

See Also: