Spark-RDD-countByValue

2017-07-18  本文已影响0人  Zachary4biz

rdd.countByValue

dfNotNull.map(_.getAs[String]("allSixId")).filter(_.startsWith("advertising_id_s")).countByValue.toList.filter(_._2 > 1).sortBy(_._2).foreach(println)
上一篇 下一篇

猜你喜欢

热点阅读