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