1. 程式人生 > >spark在HDFS上儲存/讀取 map

spark在HDFS上儲存/讀取 map

儲存:
序列化以後儲存位ObjectFile

val sc =spark.sparkContext
var EncodeMap = scala.collection.mutable.Map[String,Map[String,Int]]()
sc.parallelize(EncodeMap.toSeq).saveAsObjectFile(feature_map_path)

讀取:
先定義Map結構,再以ObjectFile讀取

 type lookup =(String,Map[String,Int])
 val fea_map = sc.objectFile[lookup](feature_map_path)
.collectAsMap()

其他資料結構也可以按照此方式儲存和讀取