Nicht in der Lage, einen Akkumulator vom Typ String zu deklarieren
Ich versuche, eine Akkumulatorvariable vom Typ String in der Scala-Shell (Treiber) zu definieren, erhalte jedoch weiterhin den folgenden Fehler: -
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")
^
Dies scheint für Akkus vom Typ Int oder Double kein Problem zu sein.
Vielen Dan