73.Spark大型电商项目-用户访问session分析-算子调优之reduceByKey本地聚合介绍

目录 reduceByKey 本篇文章记录用户访问session分析-算子调优之reduceByKey本地聚合介绍。 reduceByKey val lines = sc.textFile("hdfs://") val words = lines.flatMap(_.split(" ")) val pairs = words.map((_, 1)) val counts = pairs.reduc

>>阅读原文<<