Spark API 详解/大白话解释 之 groupBy、groupByKey

groupBy(function) function返回key，传入的RDD的各个元素根据这个key进行分组python val a = sc.parallelize(1 to 9, 3) a.groupBy(x => { if (x % 2 == 0) "even" else "odd" }).collect//分红两组 /*结果 Array( (even,ArrayBuffer(2, 4, 6

>>阅读原文<<