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

>>阅读原文<<