相关疑难解决方法(0)

我试图在Scala shell(驱动程序)中定义String类型的累加器变量,但我不断收到以下错误: -

scala> val myacc = sc.accumulator("Test")
<console>:21: error: could not find implicit value for parameter param: org.apache.spark.AccumulatorParam[String]
       val myacc = sc.accumulator("Test")
                                 ^

对于Int或Double类型的累加器来说,这似乎没有问题.

谢谢