Subject: Using Spark Accumulators with Structured Streaming

Thanks! I will take a look at the link. Just one question, you seem to be
passing 'accumulators' in the constructor but where do you use it in the
StateUpdateTask class? I am still missing that connection. Sorry, if my
question is dumb. I must be missing something. Thanks for your help so far.
It's been useful.
On Fri, May 29, 2020 at 6:51 AM Srinivas V <[EMAIL PROTECTED]> wrote: