hi all
 i am trying to replicate the Streaming Wordcount example described here

https://github.com/apache/spark/blob/master/examples/src/main/scala/org/apache/spark/examples/streaming/StatefulNetworkWordCount.scala

in my build,sbt i have the following dependencies

.....
libraryDependencies += "org.apache.spark" %% "spark-core"   % "1.5.2" %
"provided"
libraryDependencies += "org.apache.spark" %% "spark-streaming"   % "1.5.2"
% "provided"
libraryDependencies += "org.apache.spark" %% "spark-mllib"   % "1.5.2"  %
"provided"
libraryDependencies += "org.apache.spark" %% "spark-streaming-flume"   %
"1.3.0"  % "provided"
...
But compilations fail mentioning that class StateSpec and State are not
found

Could pls someone point me to the right packages to refer if i want to use
StateSpec?

kind regards
 marco

Reply via email to