scala> val file=sc.textFile("/workspace/bpUserinfo_logs/bpUserinfo_20160212.log")
scala> val count=file.flatMap(line => line.split(" ")).map(word => (word,1)).reduceByKey(_+_)
scala> count.collect().map(print)
相关文章：
相似解决方案
热门标签
scala> val file=sc.textFile("/workspace/bpUserinfo_logs/bpUserinfo_20160212.log")
scala> val count=file.flatMap(line => line.split(" ")).map(word => (word,1)).reduceByKey(_+_)
scala> count.collect().map(print)
相关文章：