智慧不是别的,而是一种组织得很好的知识体系。——乌申斯基
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版权协议,转载请附上原文出处链接及本声明。

results matching ""

    No results matching ""