© 1999-2048 dssz.net 粤ICP备11031372号
[spark] Apache Spark源码读解
说明: class WordCount{ def main(args:Array[String]):Unit={ val conf =new SparkConf().setAppName("test").setMaster("local") val sc =new SparkContext(conf) sc.textFile(“”) .flatMap(_.split(", ")) .map((_.1)) .reduceByKey(_+_) .saveAsText("") } } ...展开收缩<cvzhanshi> 在 上传 | 大小:410624