You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@spark.apache.org by Daniel Haviv <da...@veracity-group.com> on 2016/06/23 12:04:25 UTC

Confusion regarding sc.accumulableCollection(mutable.ArrayBuffer[String]()) type

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