Thats a great idea. I will try that. Thanks. On Sat, Jan 28, 2017 at 2:35 AM, Tathagata Das <tathagata.das1...@gmail.com> wrote:
> 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 >> > >
