apache-spark Stateful operations in Spark Streaming