hmm, I finally found that the following syntax works better :
scala> val mappingFunction = (key: String, value: Option[Int], state:
State[Int]) => {
| Option(key)
| }
mappingFunction: (String, Option[Int], org.apache.spark.streaming.State[Int])
=> Option[String] =
scala> val spec = S
Hi,
I'm testing a sample code and I get this error. Here is the sample code I use :
scala> import org.apache.spark.streaming._
import org.apache.spark.streaming._
scala> def mappingFunction(key: String, value: Option[Int], state: State[Int]):
Option[String] = {
|Option(key)
| }
ma
