🌈 搜索
📅  最后修改于: 2022-03-11 15:00:04.653000             🧑  作者: Mango
val df=rdd.flatMap(x=>x.split(" ")).map(x=>(x,1)).reduceByKey((x,y)=>(x+y)).toDF("word","count")