spark笔记二之Spark程序模型Transformation算子与action算子

Spark程序模型java textFile读取文件 val file=sc.textFile(“hdfs://192.168.192.137:9000/data/t1.csv”) filter函数过滤带“a”的行，输出errors（errors也是一个RDD）web filter(func) val errors=file.filter(line=>line.contains(“a”)) cou

>>阅读原文<<