Hi, I want to to use an accumulableCollection of type mutable.ArrayBuffer[String ] to return invalid records detected during transformations but I don't quite get it's type:
val errorAccumulator: Accumulable[ArrayBuffer[String], String] = sc.accumulableCollection(mutable.ArrayBuffer[String]()) Why am I getting an Accumulable[ArrayBuffer[String], String] object and not an Accumulable[ArrayBuffer[String]] ? Thank you. Daniel
