Re: Merge the states of different partition in streaming

2016-09-28 Thread Ufuk Celebi
Great to hear! On Wed, Sep 28, 2016 at 5:18 PM, Simone Robutti wrote: > Solved. Probably there was an error in the way I was testing. Also I > simplified the job and it works now. > > 2016-09-27 16:01 GMT+02:00 Simone Robutti : >> >>

Re: Merge the states of different partition in streaming

2016-09-28 Thread Simone Robutti
Solved. Probably there was an error in the way I was testing. Also I simplified the job and it works now. 2016-09-27 16:01 GMT+02:00 Simone Robutti : > Hello, > > I'm dealing with an analytical job in streaming and I don't know how to > write the last part. > >

Merge the states of different partition in streaming

2016-09-27 Thread Simone Robutti
Hello, I'm dealing with an analytical job in streaming and I don't know how to write the last part. Actually I want to count all the elements in a window with a given status, so I keep a state with a Map[Status,Long]. This state is updated starting from tuples containing the oldStatus and the