1 state object for each user. union both streams into a single DStream, and apply mapWithState on it to update the user state.
On Sat, Jan 28, 2017 at 12:30 AM, shyla deshpande <deshpandesh...@gmail.com> wrote: > Can multiple DStreams manipulate a state? I have a stream that gives me > total minutes the user spent on a course material. I have another stream > that gives me chapters completed and lessons completed by the user. I > want to keep track for each user total_minutes, chapters_completed and > lessons_completed. I am not sure if I should have 1 state or 2 states. Can > I lookup the state for a given key just like a map outside the mapfunction? > > Appreciate your input. Thanks >
