scala.collection.Map
mapValues 顧名思義,僅對 values 進行映射,也即 key 保持不變,所以要求,原始數據必須是鍵值對。
val animals = sc.parallelize(List("Dog", "Cat", "Tiger", "Cat"), 2)
val m1 = animals.map(x => (x.length, x))
val m2 = m1.mapValues("x"+_+"x").collect
scala> val cnt = animals.countByValue()
scala.collection.Map[String,Long] = Map(Dog -> 1, Cat -> 2, Tiger -> 1)
scala> cnt.toSeq
Seq[(String, Long)] = ArrayBuffer((Dog,1), (Cat,2), (Tiger,1))
版权声明:本站所有资料均为网友推荐收集整理而来,仅供学习和研究交流使用。
工作时间:8:00-18:00
客服电话
电子邮件
admin@qq.com
扫码二维码
获取最新动态