Hello,
I have a case where I am continuously getting a bunch sensor-data which is
being stored into a Cassandra table (through Kafka). Every week or so, I want
to manually enter additional data into the system - and I want this to trigger
some calculations merging the manual entered data, and t
util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:748)
Any ideas about how to handle this error?
Thanks,
Martin Engen
________
From: Lalwani, Jayesh
Sent: Tuesday, May 15, 2018 9:59 PM
To: Marti
Hello,
I'm working with Structured Streaming, and I need a method of keeping a running
average based on last 24hours of data.
To help with this, I can use Exponential Smoothing, which means I really only
need to store 1 value from a previous calculation into the new, and update this
variable as
