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())
^*
