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 >> > >
