智慧不是别的,而是一种组织得很好的知识体系。——乌申斯基
public static void mapValues()
{
//创建SparkConf
SparkConf conf = new SparkConf().setAppName("map").setMaster("local");
//创建javaSparkContext
JavaSparkContext sc = new JavaSparkContext(conf);
JavaPairRDD<String,String> pairRDD = sc.parallelizePairs(Lists.newArrayList(new Tuple2<String, String>("a","1"),
new Tuple2<String, String>("b","2"),new Tuple2<String, String>("a","3"),new Tuple2<String, String>("b","4")));
JavaPairRDD<String,String> mapValueRDD=pairRDD.mapValues(new Function<String, String>() {
public String call(String s) throws Exception {
return s+"test";
}
});
}
答案: A
;
版权声明:
本文为智客工坊「楠木大叔」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
