No se puede declarar el acumulador de tipo cadena
Estoy tratando de definir una variable acumuladora de tipo String en Scala shell (controlador) pero sigo recibiendo el siguiente error: -
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")
^
Esto parece no ser un problema para el tipo de acumulador Int o Double.
Gracias