利用时间是一个极其高级的规律。——恩格斯
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版权协议,转载请附上原文出处链接及本声明。