Re: Invalidating/Remove complete mapWithState state

2017-04-17 Thread Matthias Niehoff
That would be the hard way, but if possible I want to clear the cache without stopping the application, maybe triggered by a message in the stream. Am 17. April 2017 um 19:41 schrieb ayan guha : > It sounds like you want to stop the stream process, wipe out the check > point

Re: Invalidating/Remove complete mapWithState state

2017-04-17 Thread ayan guha
It sounds like you want to stop the stream process, wipe out the check point and restart? On Mon, 17 Apr 2017 at 10:13 pm, Matthias Niehoff < matthias.nieh...@codecentric.de> wrote: > Hi everybody, > > is there a way to complete invalidate or remove the state used by > mapWithState, not only for

Invalidating/Remove complete mapWithState state

2017-04-17 Thread Matthias Niehoff
Hi everybody, is there a way to complete invalidate or remove the state used by mapWithState, not only for a given key using State#remove()? Deleting the state key by key is not an option, as a) not all possible keys are known(might be work around of course) and b) the number of keys is to big