利用时间是一个极其高级的规律。——恩格斯
public static void map(){
        //创建SparkConf
        SparkConf conf = new SparkConf().setAppName("map").setMaster("local");
        //创建javaSparkContext
        JavaSparkContext sc = new JavaSparkContext(conf);
        //构建集合
        List<String> list = Arrays.asList("a","b","c","d","e");
        //并行化集合,创建初始RDD
        JavaRDD<String> strRDD = sc.parallelize(list);

        JavaRDD<String> rdd = strRDD.map(new Function<String, String>() {
            public String call(String v) throws Exception {
                return v +"1";
            }
        });
        rdd.foreach(new  VoidFunction<String>() {
            public void call(String t) throws Exception {
                System.out.println(t);
            }
        });

        sc.close();
    }
答案: B
;
版权声明: 本文为智客工坊「楠木大叔」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。

results matching ""

    No results matching ""