Please share your thoughts..... On Tue, Jan 24, 2017 at 4:01 PM, shyla deshpande <deshpandesh...@gmail.com> wrote:
> > > On Tue, Jan 24, 2017 at 9:44 AM, shyla deshpande <deshpandesh...@gmail.com > > wrote: > >> My streaming application stores lot of aggregations using mapWithState. >> >> I want to know what are all the possible ways I can make it idempotent. >> >> Please share your views. >> >> Thanks >> >> On Mon, Jan 23, 2017 at 5:41 PM, shyla deshpande < >> deshpandesh...@gmail.com> wrote: >> >>> In a Wordcount application which stores the count of all the words >>> input so far using mapWithState. How do I make sure my counts are not >>> messed up if I happen to read a line more than once? >>> >>> Appreciate your response. >>> >>> Thanks >>> >> >> >
