海内存知已,天涯若比邻。——王勃
/**
* flatmap算子
* 数据处理
* */
public static void flatmapDemo(){
//创建SparkConf
SparkConf conf = new SparkConf().setAppName("flatmap").setMaster("local");
//创建javaSparkContext
JavaSparkContext sc = new JavaSparkContext(conf);
//构建JavaRDD
List<String> words = Arrays.asList("a_1", "b_2", "c_3", "d_4");
JavaRDD<String> inputRDD = sc.parallelize(words);
// 使用flatmap()对字符串进行分词,得到一组单词
JavaRDD<String> result = inputRDD.flatMap(new FlatMapFunction<String, String>() {
@Override
public Iterator<String> call(String s) throws Exception {
return Arrays.asList(s.split("_")).iterator();
}
});
//输出
result.foreach(new VoidFunction<String>() {
@Override
public void call(String s) throws Exception {
System.out.println(s);
}
});
}
答案: D
;
版权声明:
本文为智客工坊「楠木大叔」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
