imagine an input stream transformed by updateStateByKey, based on some
state.
as an output of the transformation, i would like to have a stream of state
changes only - not the stream of states themselves.
what is the natural way of obtaining such a stream?
imagine an input stream transformed by updateStateByKey, based on some state.
as an output of the transformation, i would like to have a stream of state
changes only - not the stream of states themselves.
what is the natural way of obtaining such a stream?
--
View this message in context:
