论坛 › spark › spark简单例子

甩祸 发表于 2019-1-30 12:35:50

spark简单例子

　　一、统计指定索引的每个值有多少个：
　　var textFile = sc.textFile("/xxxx_orgn/p1_day=20170609/*.txt");
　　var pairRdd=textFile.filter(x=>x.split("\\|",-1).length>68).map{x=>val data=x.split("\\|",-1)(67); (data,1)}
　　var result=pairRdd.reduceByKey((sum,x)=>sum+x)
　　result.collect.foreach(println)
　　

　　二、统计数据列数
　　var textFile = sc.textFile("/xxxx_orgn/p1_day=20170609/*.txt");
　　var pairRdd=textFile.map{x=>val data=x.split("\\|",-1).length; (data,1)}
　　var result=pairRdd.reduceByKey((sum,x)=>sum+x)
　　result.collect.foreach(println)
　　

查看完整版本: spark简单例子