The state store for structured streaming is an internal concept, and isn't
designed to be consumed by end users. I'm hoping to write some
documentation on how to do aggregation, but support for reading from Kafka
and other sources will likely come in Spark 2.1+
On Wed, May 18, 2016 at 3:50 AM,
Hi
What is the right way of using spark2.0 state store feature in spark
streaming??I referred test cases in
this(https://github.com/apache/spark/pull/11645/files) pull request and
implemented word count using state store.My source is kafka(1 topic, 10
partitions). My data pump is pushing
