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 >
