把一个pair里的values变成一个数组，然后k-v1 k-v2... 如果是mapValues会输出：【对比区别】 (mobin,List(22, male))(kpop,List(20, male))(lufei,List(23, male)) ...
分类：
其他好文 时间：
2019-08-11 13:37:25
阅读次数：
207
算子总结 1.变换操作,包括过滤，变换，去重，排序,分区操作 filter过滤操作，无法触发重新分区 map,flatMap,flatMapValues,mapValues,mapPartitions,mapPartitionsWithIndex, mapPartitionsWithSplit,zi ...
分类：
其他好文 时间：
2019-04-16 11:54:01
阅读次数：
165
fold 操作 区别 与 co 1.mapValus 2.flatMapValues 3.comineByKey 4.foldByKey 5.reduceByKey 6.groupByKey 7.sortByKey 8.cogroup 9.join 10.LeftOutJoin 11.RightOu... ...
分类：
其他好文 时间：
2018-01-16 13:58:44
阅读次数：
341
package com.latrobe.spark
import org.apache.spark.{SparkContext, SparkConf}
/**
* Created by spark on 15-1-18.
*/
object FlatMapValues {
def main(args: Array[String]) {
val conf = new SparkC...
分类：
其他好文 时间：
2015-01-18 22:43:54
阅读次数：
384
