I am using following code snippet in scala:

*val dict: RDD[String] = sc.textFile("path/to/csv/file")*
*val dict_broadcast=sc.broadcast(dict.collectAsMap())*

On compiling It generates this error:

*scala:42: value collectAsMap is not a member of
org.apache.spark.rdd.RDD[String]*


*val dict_broadcast=sc.broadcast(dict.collectAsMap())
              ^*

Reply via email to