关于Scala中collectAsMap和collect().toMap

在执行以下代码后,进行广播变量
val stop_dict = sc.textFile(stopwords).map((_,0)).collectAsMap()
然后取值进行类型转换时
val stopKeyWords = args(1).asInstanceOf[Broadcast[Map[String,Int]]].value
出现以下错误
scala.collection.mutable.HashMap cannot be cast to scala.collection.immutable.Map
将原代码改为:
val stop_dict = sc.textFile(stopwords).map((_,0)).collect().toMap
方可继续运行


版权声明:本文为yuan_yiyi原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。