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

>>阅读原文<<